Skip to content

Commit

Permalink
Merge pull request #242 from kdudka/tasks-to-assign
Browse files Browse the repository at this point in the history
worker: fix a misleading debug message
  • Loading branch information
rohanpm authored Jan 11, 2024
2 parents 3e393cb + eac88ff commit 7827624
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions kobo/worker/taskmanager.py
Original file line number Diff line number Diff line change
Expand Up @@ -306,11 +306,11 @@ def get_next_task(self):

return

assigned_task_list = self.hub.worker.get_tasks_to_assign()
self.log_debug("Current assigned tasks: %r" % [ti["id"] for ti in assigned_task_list])
tasks_to_open = self.hub.worker.get_tasks_to_assign()
self.log_debug("Current tasks to open: %r" % [ti["id"] for ti in tasks_to_open])

# process assigned tasks first
for task_info in assigned_task_list:
# process tasks that could be transitioned to the OPEN state
for task_info in tasks_to_open:
self.take_task(task_info)

def take_task(self, task_info):
Expand Down

0 comments on commit 7827624

Please sign in to comment.