We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dc34cfe commit f0959cfCopy full SHA for f0959cf
1 file changed
src/scheduler/kubernetes/scheduler.py
@@ -926,6 +926,12 @@ def handle_timeouts(self):
926
WHERE id = %s and state = 'running' """, (job_id,))
927
cursor.close()
928
929
+ # Delete the k8s resource so the pod receives SIGTERM and has
930
+ # terminationGracePeriodSeconds (60s) to run finalize_upload(),
931
+ # which uploads /infrabox/upload/archive. kube_delete_job is
932
+ # idempotent — safe if the resource is already being deleted.
933
+ self.kube_delete_job(job_id)
934
+
935
def upload_console(self, job_id):
936
cursor = self.conn.cursor()
937
cursor.execute("begin")
0 commit comments