Add queue ID report before pulling task

This commit is contained in:
allegroai 2024-02-29 13:52:17 +02:00
parent 85049d8705
commit b34329934b

View File

@ -1042,6 +1042,8 @@ class K8sIntegration(Worker):
print("No tasks in queue {}".format(queue))
continue
print('Received task {} from queue {}'.format(task_id, queue))
task_session = None
if self._impersonate_as_task_owner:
try: