feat: add task event input (#444)

sam-goodwin · Sep 12, 2023 · cf37af3 · cf37af3
1 parent 622be75
commit cf37af3
Show file tree

Hide file tree

Showing 5 changed files with 102 additions and 98 deletions.
diff --git a/packages/@eventual/cli/src/display/event.ts b/packages/@eventual/cli/src/display/event.ts
@@ -44,7 +44,8 @@ export function displayEvent(event: WorkflowEvent) {
             : []),
           ...("signalId" in event ? [`Signal Id: ${event.signalId}`] : []),
           ...((isChildWorkflowScheduled(event.event) ||
-            isTransactionRequest(event.event)) &&
+            isTransactionRequest(event.event) ||
+            isTaskScheduled(event.event)) &&
           event.event.input
             ? [`Payload: ${JSON.stringify(event.event.input)}`]
             : []),

diff --git a/packages/@eventual/core-runtime/src/workflow/call-executors-and-factories/task-call.ts b/packages/@eventual/core-runtime/src/workflow/call-executors-and-factories/task-call.ts
@@ -67,6 +67,7 @@ export class TaskCallEventualFactory implements EventualFactory<TaskCall> {
         return {
           name: call.name,
           seq,
+          input: call.input,
           type: WorkflowCallHistoryType.TaskScheduled,
         };
       },

diff --git a/packages/@eventual/core-runtime/test/call-util.ts b/packages/@eventual/core-runtime/test/call-util.ts
@@ -154,11 +154,12 @@ export function workflowFailed(error: any, seq: number): ChildWorkflowFailed {
   };
 }
 
-export function taskScheduled(name: string, seq: number) {
+export function taskScheduled(name: string, seq: number, input?: any) {
   return callEvent<TaskScheduled>({
     type: WorkflowCallHistoryType.TaskScheduled,
     name,
     seq,
+    input,
   });
 }