utensil.loopflow package

Submodules

utensil.loopflow.loopflow module

class utensil.loopflow.loopflow.BaseNode(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)[source]

Bases: multiprocessing.context.Process

class utensil.loopflow.loopflow.BaseNodeProcess(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)[source]

Bases: multiprocessing.context.Process

class utensil.loopflow.loopflow.NodeProcessFunction[source]

Bases: object

classmethod parse(o) → List[utensil.loopflow.loopflow.NodeProcessFunction][source]
abstract main(*args, **kwargs)[source]
class utensil.loopflow.loopflow.NodeProcessMeta(node_name: 'str', triggerings: 'List[Node]', children: 'List[Node]', process_funcs: 'List[NodeProcessFunction]', export: 'Tuple[str]', result_q: 'SimpleQueue', end_q: 'SimpleQueue')[source]

Bases: object

node_name: str
triggerings: List[utensil.loopflow.loopflow.Node]
children: List[utensil.loopflow.loopflow.Node]
process_funcs: List[utensil.loopflow.loopflow.NodeProcessFunction]
export: Tuple[str]
result_q: multiprocessing.context.BaseContext.SimpleQueue
end_q: multiprocessing.context.BaseContext.SimpleQueue
class utensil.loopflow.loopflow.NodeProcessBuilder[source]

Bases: object

build(*args, **kwargs)[source]
class utensil.loopflow.loopflow.NodeProcess(meta: utensil.loopflow.loopflow.NodeProcessMeta, *args, **kwargs)[source]

Bases: utensil.loopflow.loopflow.BaseNodeProcess

run() → None[source]

Method to be run in sub-process; can be overridden in sub-class

class utensil.loopflow.loopflow.ParentSpecifier(node_name: 'str', flow_condition: 'Tuple[str]', flows: 'Tuple[Any]', flow_use: 'Tuple[str]')[source]

Bases: object

node_name: str
flow_condition: Tuple[str]
flows: Tuple[Any]
flow_use: Tuple[str]
classmethod parse(s)[source]
class utensil.loopflow.loopflow.ParentSpecifiers(iterable=(), /)[source]

Bases: tuple

classmethod parse(list_str: Union[str, List[str]])[source]
class utensil.loopflow.loopflow.Parents(args=None, kwargs=None)[source]

Bases: object

classmethod parse(o)[source]
class utensil.loopflow.loopflow.Triggers(args=None, kwargs=None)[source]

Bases: utensil.loopflow.loopflow.Parents

classmethod parse(o)[source]
class utensil.loopflow.loopflow.TriggerToken[source]

Bases: object

class utensil.loopflow.loopflow.Node(name: str, end: bool, proc_funcs: List[utensil.loopflow.loopflow.NodeProcessFunction], end_q: multiprocessing.context.BaseContext.SimpleQueue, result_q: multiprocessing.context.BaseContext.SimpleQueue, triggers: Union[None, utensil.loopflow.loopflow.Triggers] = None, parents: Union[None, utensil.loopflow.loopflow.Parents] = None, export: Union[None, str, List[str]] = None)[source]

Bases: utensil.loopflow.loopflow.BaseNode

push(param, caller_name)[source]
trigger(param, caller_name)[source]
run() → None[source]

Method to be run in sub-process; can be overridden in sub-class

classmethod parse(name, o, end_q: multiprocessing.context.BaseContext.SimpleQueue, result_q: multiprocessing.context.BaseContext.SimpleQueue)[source]
class utensil.loopflow.loopflow.Flow(nodes: List[utensil.loopflow.loopflow.Node], result_q: multiprocessing.context.BaseContext.SimpleQueue)[source]

Bases: object

classmethod parse(o)[source]
classmethod parse_yaml(flow_path)[source]
start()[source]
utensil.loopflow.loopflow.camel_to_snake(s)[source]
utensil.loopflow.loopflow.default_node_process_function_name(c: Type[utensil.loopflow.loopflow.NodeProcessFunction])[source]
utensil.loopflow.loopflow.reset_node_process_functions()[source]
utensil.loopflow.loopflow.register_node_process_functions(proc_funcs: Optional[List[Type[utensil.loopflow.loopflow.NodeProcessFunction]]] = None, proc_func_map: Optional[Dict[str, Type[utensil.loopflow.loopflow.NodeProcessFunction]]] = None, proc_func_module: Optional[module] = None, raise_on_exist: bool = True)[source]

Module contents

previous

utensil.general package

next

utensil.loopflow.functions package