Skip to content

Commit d1b4556

Browse files
stephanosclaude
andcommitted
Drop wait_for_signal in favor of generic state-poke signal
Express handler-side gating using the existing before_actions + AwaitWorkflowState primitives. The "unblock" signal on NexusHandlerWorkflow now just sets workflow_state.kvs["unblocked"]="1", so callers compose "block then unblock" without a dedicated proto knob. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
1 parent 6986c2d commit d1b4556

10 files changed

Lines changed: 3238 additions & 5897 deletions

File tree

loadgen/kitchen-sink-gen/src/main.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -730,7 +730,6 @@ impl ExecuteNexusOperation {
730730
before_actions: vec![],
731731
handler_workflow_id: String::new(),
732732
handler_workflow_id_conflict_policy: 0,
733-
wait_for_signal: false,
734733
})
735734
}
736735
}
@@ -776,7 +775,6 @@ impl<'a> Arbitrary<'a> for ExecuteNexusOperation {
776775
before_actions,
777776
handler_workflow_id: String::new(),
778777
handler_workflow_id_conflict_policy: 0,
779-
wait_for_signal: false,
780778
})
781779
}
782780
}

0 commit comments

Comments
 (0)