Pass task_id when resolving k8s template

This commit is contained in:
allegroai 2024-04-01 11:37:01 +03:00
parent 3d43240c8f
commit 43443ccf08

View File

@ -570,7 +570,7 @@ class K8sIntegration(Worker):
print("Kubernetes scheduling task id={}".format(task_id))
try:
template = self._resolve_template(task_session, task_data, queue)
template = self._resolve_template(task_session, task_data, queue, task_id)
except Exception as ex:
print("ERROR: Failed resolving template (skipping): {}".format(ex))
return
@ -1106,7 +1106,7 @@ class K8sIntegration(Worker):
self._session, queue=queue, get_task_info=get_task_info
)
def _resolve_template(self, task_session, task_data, queue):
def _resolve_template(self, task_session, task_data, queue, task_id):
if self.template_dict:
return deepcopy(self.template_dict)