Added the posiblity to specify a target operator when creating a workflow/workflow instance.

src/dashboard/Synapse.Dashboard/Components/CreateWorkflowInstanceDialog/CreateWorkflowInstanceDialog.razor

@@ -47,6 +47,20 @@
     </Tab>
 </Tabs>
 
+<div class="py-3">
+    @if (Operators != null && Operators.Count() > 0)
+    {
+        <select class="form-select m-2" @onchange="OnSelectOperatorChanged">
+            <option value="">Any Operator</option>
+            @foreach (var op in Operators)
+            {
+                var name = op.GetName() + "." + op.GetNamespace();
+                <option value="@name" selected="@(name == operatorName)">@name</option>
+            }
+        </select>
+    }
+</div>
+
 <div class="text-center">
     <Button Outline="true" Color="ButtonColor.Primary" class="m-auto mt-3 w-100" @onclick="async _ => await OnStartAsync()">
         <Icon Name="IconName.Play" />
@@ -61,10 +75,13 @@
     string payload = string.Empty;
     string modelName = string.Empty;
     EquatableDictionary<string, object>? input;
+    string? operatorName;
 
     [Parameter] public WorkflowDefinition? WorkflowDefinition { get; set; }
+    [Parameter] public IEnumerable<Operator> Operators { get; set; } = [];
+    [Parameter] public string? OperatorName { get; set; } = null;
     [Parameter] public EquatableDictionary<string, object>? Input { get; set; }
-    [Parameter] public EventCallback<string> OnCreate { get; set; }
+    [Parameter] public EventCallback<CreateWorkflowInstanceParameters> OnCreate { get; set; }
     [Parameter] public EventCallback<ProblemDetails> OnProblem { get; set; }
 
     void OnValueChanged(object? value)
@@ -81,6 +98,7 @@
     {
         await base.OnParametersSetAsync();
         if (input != Input) input = Input;
+        if (operatorName != OperatorName) operatorName = OperatorName;
         if (workflowDefinition != WorkflowDefinition) 
         {
             workflowDefinition = WorkflowDefinition;
@@ -93,6 +111,11 @@
         }
     }
 
+    protected void OnSelectOperatorChanged(ChangeEventArgs e)
+    {
+        operatorName = e.Value?.ToString();
+    }
+
     async Task OnStartAsync()
     {
         if (schema != null)
@@ -111,7 +134,13 @@
                 return;
             }
         }
-        if (OnCreate.HasDelegate) await OnCreate.InvokeAsync(payload);
+        if (OnCreate.HasDelegate)
+        {
+            await OnCreate.InvokeAsync(new CreateWorkflowInstanceParameters() { 
+                Input = payload,
+                Operator = operatorName
+            });
+        }
     }
 
     async Task LoadSchemaAsync()

src/dashboard/Synapse.Dashboard/Components/CreateWorkflowInstanceDialog/CreateWorkflowInstanceParameters.cs

@@ -0,0 +1,30 @@
+// Copyright © 2024-Present The Synapse Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License"),
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+namespace Synapse.Dashboard.Components;
+
+/// <summary>
+/// Represents the parameters for creating a new workflow instance.
+/// </summary>
+public record CreateWorkflowInstanceParameters
+{
+    /// <summary>
+    /// Gets/sets the workflow instance input.
+    /// </summary>
+    public string? Input { get; set; }
+
+    /// <summary>
+    /// Gets/sets the workflow instance operator.
+    /// </summary>
+    public string? Operator { get; set; }
+}

src/dashboard/Synapse.Dashboard/Pages/Workflows/Create/State.cs

@@ -12,6 +12,7 @@
 // limitations under the License.
 
 using ServerlessWorkflow.Sdk.Models;
+using Synapse.Resources;
 
 namespace Synapse.Dashboard.Pages.Workflows.Create;
 
@@ -96,6 +97,16 @@ public record CreateWorkflowViewState
     /// </summary>
     public int ProblemStatus { get; set; } = 0;
 
+    /// <summary>
+    /// Gets a <see cref="EquatableList{T}"/> that contains all <see cref="Operator"/>s
+    /// </summary>
+    public EquatableList<Operator>? Operators { get; set; }
+
+    /// <summary>
+    /// Gets/sets the active operator filter
+    /// </summary>
+    public string? Operator { get; set; } = null;
+
     /// <summary>
     /// Gets/sets the list of <see cref="ProblemDetails"/> errors that occurred when trying to save the resource, if any
     /// </summary>