jobflow_remote.jobs.run module#

jobflow_remote.jobs.run.decompress_files(store: JobStore) → None[source]#

jobflow_remote.jobs.run.ping(start_time, interval=600, filename='batch_info.json')[source]#

jobflow_remote.jobs.run.run_batch_jobs(base_run_dir: str | Path, files_dir: str | Path, batch_uid: str, max_time: float | None = None, max_wait: float = 60, max_jobs: int | None = None, parallel_jobs: int | None = None, sleep_time: float = None, batch_info_fname: str | Path = 'batch_info.json') → None[source]#

jobflow_remote.jobs.run.run_remote_job(run_dir: str | Path = '.') → None[source]#: Run the job.

jobflow_remote.jobs.run.run_single_batch_jobs(base_run_dir: str | Path, files_dir: str | Path, batch_uid: str, max_time: float | None = None, max_wait: float = 60, max_jobs: int | None = None, batch_manager: LocalBatchManager | None = None, parallel_ids: dict | None = None, sleep_time: float = None) → None[source]#