(self, hq_env: HqEnv, allocation_id: str)
| 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 | |
| 48 | def to_pbs_time(time: datetime.datetime) -> str: |
no outgoing calls