diff --git a/dispatcher/dispatcher.py b/dispatcher/dispatcher.py index 5985076..05e90dc 100644 --- a/dispatcher/dispatcher.py +++ b/dispatcher/dispatcher.py @@ -285,7 +285,8 @@ def spawn_agent_job( ), ) - batch_v1.create_namespaced_job(namespace=K8S_NAMESPACE, body=job) + log.info("Creating k8s job %s", name) + batch_v1.create_namespaced_job(namespace=K8S_NAMESPACE, body=job, _request_timeout=30) log.info("Spawned job %s for role=%s task=%d", name, role, task_id)