Skip to content

Commit

Permalink
Merge db72aed into 347f218
Browse files Browse the repository at this point in the history
  • Loading branch information
Diego committed Jun 29, 2018
2 parents 347f218 + db72aed commit f70eab7
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions reana_job_controller/k8s.py
Original file line number Diff line number Diff line change
Expand Up @@ -174,8 +174,7 @@ def watch_jobs(job_db):
try:
w = watch.Watch()
for event in w.stream(
batchv1_api_client.list_job_for_all_namespaces,
_request_timeout=60):
batchv1_api_client.list_job_for_all_namespaces):
logging.info(
'New Job event received: {0}'.format(event['type']))
job = event['object']
Expand Down Expand Up @@ -233,7 +232,7 @@ def watch_jobs(job_db):
job.metadata.name))
# Delete all depending pods.
delete_options = V1DeleteOptions(
propagation_policy='Foreground')
propagation_policy='Background')
batchv1_api_client.delete_namespaced_job(
job.metadata.name, job.metadata.namespace, delete_options)
job_db[job.metadata.name]['deleted'] = True
Expand Down

0 comments on commit f70eab7

Please sign in to comment.