Skip to content

Commit c1f3663

Browse files
committed
Fix workflow ID reference in Send function to use current workflow state
1 parent e9b0391 commit c1f3663

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

dbos/system_database.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1039,7 +1039,7 @@ func (s *systemDatabase) Send(ctx context.Context, input WorkflowSendInput) erro
10391039

10401040
// Check if operation was already executed and do nothing if so
10411041
checkInput := CheckOperationExecutionDBInput{
1042-
workflowID: input.DestinationID,
1042+
workflowID: workflowState.WorkflowID,
10431043
operationID: stepID,
10441044
functionName: functionName,
10451045
tx: tx,

0 commit comments

Comments
 (0)