Skip to content

Commit 7ce58ab

Browse files
committed
fix
1 parent 4aaf993 commit 7ce58ab

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

dbos/system_database.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -821,11 +821,6 @@ func (s *sysDB) forkWorkflow(ctx context.Context, input forkWorkflowDBInput) err
821821

822822
originalWorkflow := wfs[0]
823823

824-
// Check if the workflow has completed successfully (required for forking)
825-
if originalWorkflow.Status != WorkflowStatusSuccess {
826-
return fmt.Errorf("cannot fork workflow %s: workflow must be in SUCCESS state, current state: %s", input.originalWorkflowID, originalWorkflow.Status)
827-
}
828-
829824
// Validate that startStep doesn't exceed the workflow's actual steps
830825
maxStepQuery := `SELECT COALESCE(MAX(function_id), 0) FROM dbos.operation_outputs WHERE workflow_uuid = $1`
831826
var maxStepID int

0 commit comments

Comments
 (0)