fix(Runner): provided the workflow instance spec instead of the whole…

… resource as $workflow runtime expression argument Signed-off-by: Jean-Baptiste Bianchi <[email protected]>
serverlessworkflow · Jul 3, 2024 · 9bb4953 · 9bb4953
1 parent e383dad
commit 9bb4953
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/runner/Synapse.Runner/Services/TaskExecutor.cs b/src/runner/Synapse.Runner/Services/TaskExecutor.cs
@@ -395,7 +395,7 @@ protected virtual async Task<ITaskExecutor> CreateTaskExecutorAsync(TaskInstance
     {
         var parameters = this.Task.Arguments.Clone()!;
         parameters[RuntimeExpressions.Arguments.Context] = this.Task.ContextData;
-        parameters[RuntimeExpressions.Arguments.Workflow] = this.Task.Workflow.Instance;
+        parameters[RuntimeExpressions.Arguments.Workflow] = this.Task.Workflow.Instance.Spec;
         parameters[RuntimeExpressions.Arguments.Task] = this.Task.Instance;
         parameters[RuntimeExpressions.Arguments.Input] = this.Task.Input;
         return parameters;

diff --git a/src/runner/Synapse.Runner/Services/WorkflowExecutionContext.cs b/src/runner/Synapse.Runner/Services/WorkflowExecutionContext.cs
@@ -109,7 +109,7 @@ public virtual async Task<TaskInstance> CreateTaskAsync(TaskDefinition definitio
         var filteredInput = input;
         var evaluationArguments = new Dictionary<string, object>()
         {
-            { RuntimeExpressions.Arguments.Workflow, Instance },
+            { RuntimeExpressions.Arguments.Workflow, Instance.Spec },
             { RuntimeExpressions.Arguments.Context, context }
         };
         if (definition.Input?.From is string fromExpression) filteredInput = (await this.Expressions.EvaluateAsync<object>(fromExpression, input, evaluationArguments, cancellationToken).ConfigureAwait(false))!;