Skip to content

Commit 20428a6

Browse files
committed
Remove unnecessary stub parameter
1 parent 717e36c commit 20428a6

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

durabletask/worker.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -561,7 +561,7 @@ def _execute_orchestrator(
561561
completionToken,
562562
):
563563
try:
564-
executor = _OrchestrationExecutor(self._registry, self._logger, stub)
564+
executor = _OrchestrationExecutor(self._registry, self._logger)
565565
result = executor.execute(req.instanceId, req.pastEvents, req.newEvents)
566566
res = pb.OrchestratorResponse(
567567
instanceId=req.instanceId,
@@ -947,12 +947,11 @@ def __init__(
947947
class _OrchestrationExecutor:
948948
_generator: Optional[task.Orchestrator] = None
949949

950-
def __init__(self, registry: _Registry, logger: logging.Logger, stub: stubs.TaskHubSidecarServiceStub):
950+
def __init__(self, registry: _Registry, logger: logging.Logger):
951951
self._registry = registry
952952
self._logger = logger
953953
self._is_suspended = False
954954
self._suspended_events: list[pb.HistoryEvent] = []
955-
self._stub = stub
956955

957956
def execute(
958957
self,

0 commit comments

Comments
 (0)