Skip to content

Commit 5c2728c

Browse files
committed
Fix merge issues
1 parent a55ed39 commit 5c2728c

1 file changed

Lines changed: 1 addition & 5 deletions

File tree

durabletask/worker.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -675,7 +675,7 @@ def _execute_orchestrator(
675675
executor = _OrchestrationExecutor(
676676
self._registry, self._logger,
677677
persisted_orch_span_id=persisted_orch_span_id,
678-
self.maximum_timer_interval)
678+
maximum_timer_interval=self.maximum_timer_interval)
679679
result = executor.execute(instance_id, req.pastEvents, req.newEvents)
680680

681681
# Determine completion status for span
@@ -1692,10 +1692,6 @@ def process_event(
16921692
scheduled_time_ns=created_ns,
16931693
parent_trace_context=ctx._orchestration_trace_context or ctx._parent_trace_context,
16941694
)
1695-
timer_task.complete(None)
1696-
if timer_task._retryable_parent is not None:
1697-
activity_action = timer_task._retryable_parent._action
1698-
16991695
next_fire_at = timer_task.complete(event.timerFired.fireAt.ToDatetime())
17001696
if next_fire_at is not None:
17011697
id = ctx.next_sequence_number()

0 commit comments

Comments
 (0)