fix(Runner): Fixed the Do, For and Try TaskExecutors to used Metadata instead of Extensions, which has been removed in latest SDK version

Signed-off-by: Charles d'Avernas <[email protected]>

Author: cdavernas

src/core/Synapse.Core/SynapseDefaults.cs

@@ -1065,9 +1065,9 @@ public static class Tasks
     {
 
         /// <summary>
-        /// Exposes Synapse task extension properties
+        /// Exposes Synapse task metadata properties
         /// </summary>
-        public static class ExtensionProperties
+        public static class Metadata
         {
 
             /// <summary>

src/runner/Synapse.Runner/Services/Executors/DoTaskExecutor.cs

@@ -40,7 +40,7 @@ public class DoTaskExecutor(IServiceProvider serviceProvider, ILogger<DoTaskExec
     /// <param name="index">The index of the subtask to get the path to</param>
     /// <param name="name">The name of the subtask to get the path to</param>
     /// <returns>The path to the specified subtask</returns>
-    protected virtual string GetPathFor(int index, string name) => this.Task.Definition.Extensions?.TryGetValue(SynapseDefaults.Tasks.ExtensionProperties.PathPrefix.Name, out var value) == true && value is bool prefix && prefix == false
+    protected virtual string GetPathFor(int index, string name) => this.Task.Definition.Metadata?.TryGetValue(SynapseDefaults.Tasks.Metadata.PathPrefix.Name, out var value) == true && value is bool prefix && prefix == false
         ? $"{index}/{name}"
         : $"{nameof(DoTaskDefinition.Do).ToCamelCase()}/{index}/{name}";
 

src/runner/Synapse.Runner/Services/Executors/ForTaskExecutor.cs

@@ -78,9 +78,9 @@ protected override async Task DoExecuteAsync(CancellationToken cancellationToken
         var taskDefinition = new DoTaskDefinition()
         {
             Do = this.Task.Definition.Do,
-            Extensions =
+            Metadata =
             [
-                new(SynapseDefaults.Tasks.ExtensionProperties.PathPrefix.Name, false)
+                new(SynapseDefaults.Tasks.Metadata.PathPrefix.Name, false)
             ]
         };
         if (task == null) task = await this.Task.Workflow.CreateTaskAsync(taskDefinition, this.GetPathFor("0"), this.Task.Input, null, this.Task, false, cancellationToken).ConfigureAwait(false);
@@ -134,9 +134,9 @@ protected virtual async Task OnIterationCompletedAsync(ITaskExecutor executor, C
                 var taskDefinition = new DoTaskDefinition()
                 {
                     Do = this.Task.Definition.Do,
-                    Extensions =
+                    Metadata =
                     [
-                        new(SynapseDefaults.Tasks.ExtensionProperties.PathPrefix.Name, false)
+                        new(SynapseDefaults.Tasks.Metadata.PathPrefix.Name, false)
                     ]
                 };
                 var next = await this.Task.Workflow.CreateTaskAsync(taskDefinition, this.GetPathFor(index.ToString()), output, null, this.Task, false, cancellationToken).ConfigureAwait(false);

src/runner/Synapse.Runner/Services/Executors/TryTaskExecutor.cs

@@ -37,9 +37,9 @@ protected override async Task DoExecuteAsync(CancellationToken cancellationToken
         var taskDefinition = new DoTaskDefinition()
         {
             Do = this.Task.Definition.Try,
-            Extensions =
+            Metadata =
             [
-                new(SynapseDefaults.Tasks.ExtensionProperties.PathPrefix.Name, false)
+                new(SynapseDefaults.Tasks.Metadata.PathPrefix.Name, false)
             ]
         };
         var task = await this.Task.Workflow.CreateTaskAsync(taskDefinition, nameof(this.Task.Definition.Try).ToCamelCase(), this.Task.Input, null, this.Task, false, cancellationToken).ConfigureAwait(false);
@@ -60,9 +60,9 @@ protected override async Task DoRetryAsync(Error cause, CancellationToken cancel
         var taskDefinition = new DoTaskDefinition()
         {
             Do = this.Task.Definition.Try,
-            Extensions =
+            Metadata =
             [
-                new(SynapseDefaults.Tasks.ExtensionProperties.PathPrefix.Name, false)
+                new(SynapseDefaults.Tasks.Metadata.PathPrefix.Name, false)
             ]
         };
         var task = await this.Task.Workflow.CreateTaskAsync(taskDefinition, $"retry/{this.Task.Instance.Retries?.Count - 1}/try", this.Task.Input, null, this.Task, false, cancellationToken).ConfigureAwait(false);