Skip to content

Commit 1f123f0

Browse files
committed
fix for review cancelation
Signed-off-by: Neil South <neil.south@answerdigital.com>
1 parent 97bfa29 commit 1f123f0

File tree

1 file changed

+21
-2
lines changed

1 file changed

+21
-2
lines changed

src/TaskManager/Plug-ins/AideClinicalReview/AideClinicalReviewPlugin.cs

Lines changed: 21 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
* limitations under the License.
1515
*/
1616

17-
using Ardalis.GuardClauses;
1817
using Microsoft.Extensions.DependencyInjection;
1918
using Microsoft.Extensions.Logging;
2019
using Microsoft.Extensions.Options;
@@ -321,6 +320,26 @@ public async ValueTask DisposeAsync()
321320
GC.SuppressFinalize(this);
322321
}
323322

324-
public override Task HandleTimeout(string identity) => Task.CompletedTask; // not implemented
323+
public override Task HandleTimeout(string identity)
324+
{
325+
var message = GenerateCancelationMessage(identity);
326+
327+
var queue = _queueName ?? _options.Value.Messaging.Topics.AideClinicalReviewCancelation;
328+
_logger.SendClinicalReviewRequestMessage(queue, _workflowName ?? string.Empty);
329+
return _messageBrokerPublisherService.Publish(queue, message.ToMessage());
330+
}
331+
332+
private JsonMessage<TaskCancellationEvent> GenerateCancelationMessage(string identity)
333+
{
334+
return new JsonMessage<TaskCancellationEvent>(new TaskCancellationEvent
335+
{
336+
ExecutionId = identity,
337+
WorkflowInstanceId = Event.WorkflowInstanceId,
338+
TaskId = Event.TaskId,
339+
Reason = FailureReason.TimedOut,
340+
Identity = identity,
341+
Message = $"{FailureReason.TimedOut} {DateTime.UtcNow}"
342+
}, TaskManagerApplicationId, Event.CorrelationId);
343+
}
325344
}
326345
}

0 commit comments

Comments
 (0)