jobflow_remote.utils.examples module#

jobflow_remote.utils.examples.add(a, b)[source]#: A Job adding to numbers.

jobflow_remote.utils.examples.add_distributed(list_a)[source]#: A Job generating a new Flow to add a list of numbers.

jobflow_remote.utils.examples.add_many(*to_sum)[source]#: A job adding numbers.

jobflow_remote.utils.examples.add_raise(a, b) → NoReturn[source]#: A Job raising a RuntimeError.

jobflow_remote.utils.examples.conditional_sum_replace(numbers, min_n=10)[source]#: A Job creating a replace and adding number until a value is reached.

jobflow_remote.utils.examples.make_list(a, length=None)[source]#: A Job generating a list of numbers.

jobflow_remote.utils.examples.sleep(s)[source]#: A Job sleeping.

jobflow_remote.utils.examples.value(n)[source]#: A Job returning the input value.