diff --git a/clearml_agent/glue/k8s.py b/clearml_agent/glue/k8s.py index e6fddd5..07b1358 100644 --- a/clearml_agent/glue/k8s.py +++ b/clearml_agent/glue/k8s.py @@ -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: