Searched refs:active_leases (Results 1 – 1 of 1) sorted by relevance
74 active_leases = {78 _mark_expired_jobs_failed(metrics, active_leases)79 _abort_timed_out_jobs(active_leases)80 _abort_jobs_marked_aborting(active_leases)86 def _mark_expired_jobs_failed(metrics, active_leases): argument101 if handoff.job_id not in active_leases:110 def _abort_timed_out_jobs(active_leases): argument116 if job.id in active_leases:118 active_leases[job.id].maybe_abort()121 def _abort_jobs_marked_aborting(active_leases): argument[all …]