Add argo workflow link on sara workflows

Author: olaals

api/Controllers/Models/WorkflowDto.cs

@@ -32,9 +32,11 @@ public WorkflowDto() { }
     public WorkflowDto(Workflow workflow, IBlobStorageService blobService)
     {
         this.Id = workflow.Id;
+        this.AnalysisRunId = workflow.AnalysisRunId;
         this.StepNumber = workflow.StepNumber;
         this.WorkflowType = workflow.WorkflowType;
         this.Status = workflow.Status;
+        this.ArgoWorkflowName = workflow.ArgoWorkflowName;
         this.OutputBlobSAS =
             workflow.OutputBlobStorageLocation != null
                 ? blobService.CreateReadSasUri(workflow.OutputBlobStorageLocation).Result
@@ -144,9 +146,11 @@ string workflowType
     }
 
     public Guid Id { get; set; }
+    public Guid AnalysisRunId { get; set; }
     public int StepNumber { get; set; }
     public string WorkflowType { get; set; }
     public WorkflowStatus Status { get; set; }
+    public string? ArgoWorkflowName { get; set; }
     public Uri? OutputBlobSAS { get; set; }
     public AnalysisResultDto? Result { get; set; }
     public string? ResultJson { get; set; }

api/Controllers/WorkflowNotificationController.cs

@@ -29,7 +29,10 @@ IWorkflowService workflowService
     [Route("{workflowId:guid}/started")]
     [ProducesResponseType(StatusCodes.Status204NoContent)]
     [ProducesResponseType(StatusCodes.Status404NotFound)]
-    public async Task<IActionResult> WorkflowStarted([FromRoute] Guid workflowId)
+    public async Task<IActionResult> WorkflowStarted(
+        [FromRoute] Guid workflowId,
+        [FromBody] WorkflowStartedNotification? notification = null
+    )
     {
         var workflow = await context.Workflows.FirstOrDefaultAsync(w => w.Id == workflowId);
         if (workflow is null)
@@ -38,13 +41,18 @@ public async Task<IActionResult> WorkflowStarted([FromRoute] Guid workflowId)
         }
 
         logger.LogInformation(
-            "Workflow {WorkflowType} (Id: {WorkflowId}) reported started",
+            "Workflow {WorkflowType} (Id: {WorkflowId}) reported started (ArgoWorkflowName: {ArgoWorkflowName})",
             workflow.WorkflowType,
-            workflow.Id
+            workflow.Id,
+            notification?.ArgoWorkflowName
         );
 
         workflow.Status = WorkflowStatus.InProgress;
         workflow.StartedAt = DateTime.UtcNow;
+        if (!string.IsNullOrWhiteSpace(notification?.ArgoWorkflowName))
+        {
+            workflow.ArgoWorkflowName = notification.ArgoWorkflowName;
+        }
         await context.SaveChangesAsync();
 
         return NoContent();
@@ -134,6 +142,11 @@ [FromBody] WorkflowExitedNotification notification
     }
 }
 
+public class WorkflowStartedNotification
+{
+    public string? ArgoWorkflowName { get; set; }
+}
+
 public class WorkflowResultNotification
 {
     public string? ResultJson { get; set; }

api/Database/Models/Workflow.cs

@@ -60,6 +60,13 @@ public class Workflow
 
     public WorkflowStatus Status { get; set; } = WorkflowStatus.Pending;
 
+    /// <summary>
+    /// Name of the underlying Argo Workflow resource, reported by the workflow
+    /// notifier when the workflow starts. Combined with the SARA-configured Argo
+    /// Workflows base URL and namespace to build a deep link to the Argo UI.
+    /// </summary>
+    public string? ArgoWorkflowName { get; set; }
+
     public BlobStorageLocation? OutputBlobStorageLocation { get; set; }
 
     public string? ResultJson { get; set; }