Broken - needs more work

src/SIL.Machine.AspNetCore/Services/ClearMLService.cs

@@ -146,10 +146,11 @@ public async Task<bool> StopTaskAsync(string id, CancellationToken cancellationT
     }
 
     public async Task<IReadOnlyList<ClearMLTask>> GetTasksForCurrentQueueAsync(
+        string? queueName = null,
         CancellationToken cancellationToken = default
     )
     {
-        var body = new JsonObject { ["name"] = _options.CurrentValue.Queue };
+        var body = new JsonObject { ["name"] = queueName ?? _options.CurrentValue.Queue };
         JsonObject? result = await CallAsync("queues", "get_all_ex", body, cancellationToken);
         var tasks = (JsonArray?)result?["data"]?["queues"]?[0]?["entries"];
         IEnumerable<string> taskIds = tasks?.Select(t => (string)t?["id"]!) ?? new List<string>();

src/SIL.Machine.AspNetCore/Services/ITranslationEngineService.cs

@@ -40,5 +40,5 @@ Task StartBuildAsync(
 
     Task CancelBuildAsync(string engineId, CancellationToken cancellationToken = default);
 
-    Task<int> GetQueueSizeAsync(CancellationToken cancellationToken = default);
+    Task<int> GetQueueSizeAsync(string? queueName = null, CancellationToken cancellationToken = default);
 }

src/SIL.Machine.AspNetCore/Services/NmtEngineService.cs

@@ -146,7 +146,7 @@ public Task TrainSegmentPairAsync(
         throw new NotSupportedException();
     }
 
-    public Task<int> GetQueueSizeAsync(CancellationToken cancellationToken = default)
+    public Task<int> GetQueueSizeAsync(string? queueName = null, CancellationToken cancellationToken = default)
     {
         return Task.FromResult(_clearMLMonitorService.QueueSize);
     }

src/SIL.Machine.AspNetCore/Services/ServalTranslationEngineServiceV1.cs

@@ -130,7 +130,10 @@ ServerCallContext context
     )
     {
         ITranslationEngineService engineService = GetEngineService(request.EngineType);
-        return new GetQueueSizeResponse { Size = await engineService.GetQueueSizeAsync(context.CancellationToken) };
+        return new GetQueueSizeResponse
+        {
+            Size = await engineService.GetQueueSizeAsync(request.queueName, context.CancellationToken)
+        };
     }
 
     public override async Task<HealthCheckResponse> HealthCheck(Empty request, ServerCallContext context)

src/SIL.Machine.AspNetCore/Services/SmtTransferEngineService.cs

@@ -205,7 +205,7 @@ public async Task CancelBuildAsync(string engineId, CancellationToken cancellati
         }
     }
 
-    public Task<int> GetQueueSizeAsync(CancellationToken cancellationToken = default)
+    public Task<int> GetQueueSizeAsync(string? queueName = null, CancellationToken cancellationToken = default)
     {
         return Task.FromResult(Convert.ToInt32(_jobStorage.GetMonitoringApi().EnqueuedCount("smt_transfer")));
     }