jobflow_remote.cli.job module

jobflow_remote.cli.job.delete(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>] = None, job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, wait: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a1762d0>] = None, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False, delete_output: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1765d0>] = False, delete_files: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1766d0>] = False, delete_all: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1767d0>] = False) → None

Delete Jobs individually. The Flow document will be updated accordingly but no consistency check is performed. The Flow may be left in an inconsistent state. For advanced users only.

jobflow_remote.cli.job.exec_config(exec_config_value: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b89b84a50>], job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False)

Set the exec_config for the selected Jobs. Only Jobs not in an evolving state (e.g. CHECKED_OUT, UPLOADED, …).

jobflow_remote.cli.job.files_get(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>], filenames: ~typing.Annotated[list[str], <typer.models.ArgumentInfo object at 0x7f5b89bb4410>], job_index: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175cd0>] = None, path: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b89bb44d0>] = None) → None

jobflow_remote.cli.job.files_list(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>], job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None) → None

List of files in the run_dir of the selected Job.

jobflow_remote.cli.job.job_dump(job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, file_path: ~typing.Annotated[str, <typer.models.OptionInfo object at 0x7f5b89b87b90>] = 'jobs_dump.json') → None

Dump to json the documents of the selected Jobs from the DB. For debugging.

jobflow_remote.cli.job.job_info(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>] = None, job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, pid: ~typing.Annotated[str, <typer.models.OptionInfo object at 0x7f5b89b6ff50>] = None, show_none: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b89b841d0>] = False, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0) → None

Detailed information on a specific job.

jobflow_remote.cli.job.jobs_list(job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, max_results: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a1758d0>] = 100, sort: ~jobflow_remote.cli.utils.Annotated[~jobflow_remote.cli.utils.SortOption, <typer.models.OptionInfo object at 0x7f5b8a175990>] = SortOption.UPDATED_ON, reverse_sort: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a175a50>] = False, locked: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1760d0>] = False, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b89b6fe90>] = False)

Get the list of Jobs in the database

jobflow_remote.cli.job.output(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>], job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, file_path: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b89b87dd0>] = None, load: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b89b87e10>] = False) → None

Detailed information on a specific job.

jobflow_remote.cli.job.pause(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>] = None, job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, wait: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a1762d0>] = None, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False) → None

Pause a Job. Only READY and WAITING Jobs can be paused. The operation is reversible.

jobflow_remote.cli.job.play(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>] = None, job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, wait: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a1762d0>] = None, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False) → None

Resume a Job that was previously PAUSED.

jobflow_remote.cli.job.queue_out(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>], job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None) → None

Print the content of the output files produced by the queue manager.

jobflow_remote.cli.job.rerun(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>] = None, job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, wait: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a1762d0>] = None, break_lock: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1763d0>] = False, force: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b89b843d0>] = False, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False) → None

Rerun a Job. By default, this is limited to jobs that failed and children did not start or jobs that are running. The rerun Job is set to READY and children Jobs to WAITING. If possible, the associated job submitted to the remote queue will be cancelled. Most of the limitations can be overridden by the ‘force’ option. This could lead to inconsistencies in the overall state of the Jobs of the Flow.

jobflow_remote.cli.job.resources(resources_value: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b89b84d50>], replace: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b89b858d0>] = False, qresources: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b89b85710>] = False, job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False)

Set the resources for the selected Jobs. Only Jobs not in an evolving state (e.g. CHECKED_OUT, UPLOADED, …)

jobflow_remote.cli.job.retry(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>] = None, job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, wait: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a1762d0>] = None, break_lock: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1763d0>] = False, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False) → None

Retry to perform the operation that failed for a job in a REMOTE_ERROR state or reset the number of attempts at remote action, in order to allow the runner to try it again immediately.

jobflow_remote.cli.job.set_state(state: ~jobflow_remote.jobs.state.Annotated[~jobflow_remote.jobs.state.JobState, <typer.models.ArgumentInfo object at 0x7f5b8a174d50>], job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>], job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None) → None

Sets the state of a Job to an arbitrary value. WARNING: No checks. This can lead to inconsistencies in the DB. Use with care.

jobflow_remote.cli.job.stop(job_db_id: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b8a175b10>] = None, job_index: ~typing.Annotated[int | None, <typer.models.ArgumentInfo object at 0x7f5b8a175bd0>] = None, job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, wait: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a1762d0>] = None, break_lock: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1763d0>] = False, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False) → None

Stop a Job. Only Jobs that did not complete or had an error can be stopped. The operation is irreversible. If possible, the associated job submitted to the remote queue will be cancelled.

jobflow_remote.cli.job.worker(worker_name: ~typing.Annotated[str, <typer.models.ArgumentInfo object at 0x7f5b89b84890>], job_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f290>] = None, db_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f7d0>] = None, flow_id: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a15f990>] = None, state: ~typing.Annotated[list[~jobflow_remote.jobs.state.JobState] | None, <typer.models.OptionInfo object at 0x7f5b8a174190>] = None, start_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a1753d0>] = None, end_date: ~typing.Annotated[~datetime.datetime | None, <typer.models.OptionInfo object at 0x7f5b8a175450>] = None, name: ~typing.Annotated[str | None, <typer.models.OptionInfo object at 0x7f5b8a174990>] = None, metadata: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a177010>] = None, select_worker_name: ~typing.Annotated[list[str] | None, <typer.models.OptionInfo object at 0x7f5b8a174c10>] = None, custom_query: ~typing.Annotated[~jobflow_remote.cli.types.DictType | None, <typer.models.OptionInfo object at 0x7f5b8a176fd0>] = None, days: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a175510>] = None, hours: ~typing.Annotated[int | None, <typer.models.OptionInfo object at 0x7f5b8a1755d0>] = None, verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f5b8a175690>] = 0, raise_on_error: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f5b8a1764d0>] = False)

Set the worker for the selected Jobs. Only Jobs not in an evolving state (e.g. CHECKED_OUT, UPLOADED, …).