jobflow_remote.cli.runner module#
- jobflow_remote.cli.runner.foreground() None[source]#
Connect to the daemon processes in the foreground.
- jobflow_remote.cli.runner.info(verbosity: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f2db94f6790>] = 0) None[source]#
Fetch the information about the process of the daemon. Contain the supervisord process and the processes running the Runner.
- jobflow_remote.cli.runner.kill() None[source]#
Send a kill signal to the Runner processes. Return immediately, does not wait for processes to be killed.
- jobflow_remote.cli.runner.reset(force: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db94f6f10>] = False, break_lock: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db94f7490>] = False) None[source]#
Reset the value of the machine executing the runner from the database. Should be executed only if it is certain that the runner is not active on that machine anymore.
- jobflow_remote.cli.runner.restart() None[source]#
Restart the runner. Send a stop signal, wait for the runner to stop and restart it with the same configuration.
- jobflow_remote.cli.runner.run(log_level: ~jobflow_remote.config.base.Annotated[~jobflow_remote.config.base.LogLevel, <typer.models.OptionInfo object at 0x7f2db94f6850>] = LogLevel.INFO, set_pid: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8f5b650>] = False, transfer: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8f5b190>] = False, complete: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8fb7c50>] = False, queue: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8f3ddd0>] = False, checkout: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8f643d0>] = False, connect_interactive: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8f67ad0>] = False) None[source]#
Execute the Runner in the foreground. Do NOT execute this to start as a daemon. Should be used by the daemon or for testing purposes.
- jobflow_remote.cli.runner.shutdown() None[source]#
Shuts down the supervisord process. Note that if the daemon is running it will wait for the daemon to stop.
- jobflow_remote.cli.runner.start(transfer: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f2db8f65510>] = 1, complete: ~typing.Annotated[int, <typer.models.OptionInfo object at 0x7f2db8f67f10>] = 1, single: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8f67f50>] = False, log_level: ~jobflow_remote.config.base.Annotated[~jobflow_remote.config.base.LogLevel, <typer.models.OptionInfo object at 0x7f2db94f6850>] = LogLevel.INFO, connect_interactive: ~typing.Annotated[bool, <typer.models.OptionInfo object at 0x7f2db8f67e10>] = False) None[source]#
Start the Runner as a daemon.