(hq_env: HqEnv, with_worker=True, **job_args)
| 11 | |
| 12 | |
| 13 | def prepare_job_client(hq_env: HqEnv, with_worker=True, **job_args) -> Tuple[Job, Client]: |
| 14 | hq_env.start_server() |
| 15 | if with_worker: |
| 16 | hq_env.start_worker() |
| 17 | client = Client(hq_env.server_dir) |
| 18 | return (Job(**job_args), client) |
| 19 | |
| 20 | |
| 21 | def hq_env_from_cluster(cluster: LocalCluster) -> HqEnv: |