We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9850b6b commit ce31af3Copy full SHA for ce31af3
1 file changed
azure/durable_functions/models/TaskOrchestrationExecutor.py
@@ -95,7 +95,7 @@ def execute(self, context: DurableOrchestrationContext,
95
# Combine the is_played field with the history-based signal:
96
# we are replaying if is_played says so OR if we haven't reached new events yet.
97
execution_started_event = history[1]
98
- history_is_replaying = self._new_events_start_index > 1
+ history_is_replaying = self._new_events_start_index > 0
99
self.current_task.is_played = execution_started_event.is_played or history_is_replaying
100
101
# If user code is a generator, then it uses `yield` statements (the DF API)
0 commit comments