MCPcopy Create free account
hub / github.com/It4innovations/hyperqueue / add_worker

Method add_worker

tests/autoalloc/mock/manager.py:182–184  ·  view source on GitHub ↗
(self, hq_env: HqEnv, allocation_id: str)

Source from the content-addressed store, hash-verified

180 self.deleted_jobs.add(job_id)
181
182 def add_worker(self, hq_env: HqEnv, allocation_id: str) -> Popen:
183 self.set_job_data(allocation_id, JobData.running())
184 return self.adapter.start_worker(hq_env, allocation_id)
185
186 def set_job_data(self, job_id: str, status: Optional[JobData]):
187 self.jobs[job_id] = status

Callers 6

test_restore_queue_worker_resourcesFunction · 0.45
test_allocations_job_lifecycleFunction · 0.45
test_cancel_jobs_on_server_stopFunction · 0.45
test_fail_on_remove_queue_with_running_jobsFunction · 0.45
test_cancel_active_jobs_on_forced_remove_queueFunction · 0.45
test_slurm_allocation_nameFunction · 0.45

Calls 3

set_job_dataMethod · 0.95
runningMethod · 0.45
start_workerMethod · 0.45

Tested by 6

test_restore_queue_worker_resourcesFunction · 0.36
test_allocations_job_lifecycleFunction · 0.36
test_cancel_jobs_on_server_stopFunction · 0.36
test_fail_on_remove_queue_with_running_jobsFunction · 0.36
test_cancel_active_jobs_on_forced_remove_queueFunction · 0.36
test_slurm_allocation_nameFunction · 0.36