We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ba8ae86 commit deec018Copy full SHA for deec018
1 file changed
core/src/worker/workflow/history_update.rs
@@ -718,6 +718,11 @@ fn find_end_index_of_next_wft_seq(
718
return NextWFTSeqEndIndex::Complete(last_index);
719
}
720
721
+ // TODO: Emergency undo for boundary calculation change. Remove if no problems after a bit.
722
+ if std::env::var("TEMPORAL_NO_WFT_BOUNDARY_CHANGE").is_ok() {
723
+ saw_command = false;
724
+ }
725
+
726
if e.event_type() == EventType::WorkflowTaskStarted {
727
wft_started_event_id_to_index.push((e.event_id, ix));
728
if let Some(next_event) = events.get(ix + 1) {
0 commit comments