Skip to content

Commit

Permalink
Merge pull request #113 from BrandonDotLin/main
Browse files Browse the repository at this point in the history
pass worker id when polling task
  • Loading branch information
gardusig authored Jul 27, 2022
2 parents 5f1baf5 + b66398b commit e38a408
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/conductor/client/automator/task_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ def __poll_task(self) -> Task:
try:
start_time = time.time()
task = self.__get_task_resource_api().poll(
tasktype=task_definition_name
tasktype=task_definition_name, workerid=self.worker.get_identity()
)
finish_time = time.time()
time_spent = finish_time - start_time
Expand Down

0 comments on commit e38a408

Please sign in to comment.