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

Method start_worker

tests/autoalloc/mock/pbs.py:41–45  ·  view source on GitHub ↗
(self, hq_env: HqEnv, allocation_id: str)

Source from the content-addressed store, hash-verified

39 return response(stdout=json.dumps({"Jobs": create_pbs_job_data(job_data)}))
40
41 def start_worker(self, hq_env: HqEnv, allocation_id: str) -> Popen:
42 return hq_env.start_worker(
43 env={"PBS_JOBID": allocation_id, "PBS_ENVIRONMENT": "1"},
44 args=["--manager", "pbs", "--time-limit", "30m"],
45 )
46
47
48def to_pbs_time(time: datetime.datetime) -> str:

Callers 15

test_single_depFunction · 0.45
test_long_chain_of_depsFunction · 0.45
prepare_job_clientFunction · 0.45
test_cluster_add_workerFunction · 0.45
test_print_worker_listFunction · 0.45
test_print_job_listFunction · 0.45

Calls

no outgoing calls

Tested by 15

test_single_depFunction · 0.36
test_long_chain_of_depsFunction · 0.36
test_cluster_add_workerFunction · 0.36
test_print_worker_listFunction · 0.36
test_print_job_listFunction · 0.36
test_print_worker_listFunction · 0.36