jobflow_remote.testing package

Submodules

• jobflow_remote.testing.cli module
  • run_check_cli()

Module contents

A series of toy workflows that can be used for testing.

jobflow_remote.testing.add(a, b)

Adds two numbers together and writes the answer to a file.

jobflow_remote.testing.add_big(a: float, b: float)

Adds two numbers together and inflates the answer to a large list and tries to store that within the defined store.

jobflow_remote.testing.add_big_undefined_store(a: float, b: float)

Adds two numbers together and writes the answer to an artificially large file which is attempted to be stored in a undefined store.

jobflow_remote.testing.add_sleep(a, b)

Adds two numbers together and sleeps for “b” seconds.

jobflow_remote.testing.always_fails() → NoReturn

A job that always fails.

jobflow_remote.testing.arithmetic(a: float | list[float], b: float | list[float], op: Callable | None = None) → float | None

jobflow_remote.testing.check_env_var() → str

jobflow_remote.testing.create_detour(detour_job: Job)

Create a detour based on the passed Job.

jobflow_remote.testing.ignore_input(a: int) → int

Can receive an input, but ignores it.

Allows to test flows with failed parents

jobflow_remote.testing.self_replace(n: int)

Create a replace Job with the same job n times.

jobflow_remote.testing.write_file(n) → None