Index

A

AbsoluteIdentifier (in module noob.types) add() (EventStore method) add_callback() (EventloopMixin method) (TubeRunner method) add_config_source() (in module noob.config) add_epoch() (Scheduler method) add_input() (InputCollection method) add_value() (EventStore method) AlreadyDoneError AlreadyRunningError annotation (Slot attribute) announce (MessageType attribute)

announce() (CommandNode method) AnnounceValue (class in noob.network.message) assets (State attribute) (TubeSpecification attribute) assets_exhausted_after_storage() (Tube method) AssetScope (class in noob.asset) async_error() (in module noob.testing.nodes) autoclear_store (ZMQRunner attribute) await_epoch() (ZMQRunner method) await_inputs() (NodeRunner method) await_node() (NodeRunner method) await_ready() (CommandNode method)

C

call_async_from_sync() (in module noob.runner.base) chain (InputCollection property) clear() (EventStore method) (Scheduler method) (State method) clear_callbacks() (EventloopMixin method) closed (NodeStatus attribute) cls (WrapClassAsset attribute) (WrapClassNode attribute) collect() (EventStore method) (InputCollection method) (State method) collect_events() (EventStore method) collect_return() (SynchronousRunner method) (TubeRunner method) (ZMQRunner method) command (ZMQRunner attribute)

CommandNode (class in noob.runner.zmq) concat() (in module noob.testing.nodes) config_dir (Config attribute) CONFIG_ID_PATTERN (in module noob.types) config_sources() (ConfigYAMLMixin class method) ConfigError ConfigID (in module noob.types) ConfigMismatchError ConfigSource (in module noob.types) ConfigWarning context (EventloopMixin property) count_source() (in module noob.testing.nodes) counter (class in noob.testing.assets) (EventStore attribute) CountSourceDecor (class in noob.testing.nodes) create_dir() (Config class method) (LogConfig class method) current (counter property)

D

deinit (MessageType attribute) deinit() (Asset method) (CommandNode method) (InitCounter method) (Initializer method) (Node method) (NodeRunner method) (State method) (SynchronousRunner method) (TubeNode method) (TubeRunner method) (WrapClassAsset method) (WrapClassNode method) (WrapFuncAsset method) (ZMQRunner method) dependencies (State attribute) dependencies_exist() (TubeSpecification method) DependencyIdentifier (in module noob.types)

depends (Asset attribute) (AssetSpecification attribute) (NodeRunner property) (NodeSpecification attribute) DependsType (in module noob.node.spec) description (AssetSpecification attribute) (InputSpecification attribute) (NodeSpecification attribute) (TubeSpecification attribute) dictify() (in module noob.testing.nodes) dir (LogConfig attribute) disable_node() (Scheduler method) (SynchronousRunner method) (Tube method) (TubeRunner method) (ZMQRunner method) divide() (in module noob.testing.nodes) done() (Scheduler method)

E

edges (Node property) (Scheduler attribute) (Tube attribute) enable_node() (Scheduler method) (SynchronousRunner method) (Tube method) (TubeRunner method) (ZMQRunner method) enabled (Node attribute) (NodeSpecification attribute) enabled_nodes (Tube property) end_epoch() (Scheduler method) EntrypointImportWarning epoch (Event attribute) (MetaEvent attribute) (ProcessValue attribute) epoch_completed() (Scheduler method) EpochCompletedError

EpochEnded (MetaEventType attribute) EpochExistsError err_args (ErrorValue attribute) err_type (ErrorValue attribute) error (MessageType attribute) error() (in module noob.testing.nodes) (NodeRunner method) ErrorValue (class in noob.network.message) Event (class in noob.event) event (MessageType attribute) EventDict (in module noob.store) EventloopMixin (class in noob.network.loop) events (EventStore attribute) EventStore (class in noob.store) exclaim() (in module noob.testing.nodes) expire() (Scheduler method) ExtraInputError ExtraInputWarning

F

fast_forward() (in module noob.testing.nodes) file_n (LogConfig attribute) file_size (LogConfig attribute) fill_node_ids() (TubeSpecification class method) fill_noob_model() (ConfigYAMLMixin class method) filter_input() (InputCollection method) flat_events (EventStore property) fn (WrapFuncAsset attribute) (WrapFuncNode attribute) from_any() (ConfigYAMLMixin class method)

from_bytes() (Message class method) from_callable() (Signal class method) (Slot class method) from_id() (ConfigYAMLMixin class method) from_specification() (Asset class method) (Node class method) (Scheduler class method) (State class method) (Tube class method) from_yaml() (ConfigYAMLMixin class method) (YAMLMixin class method)

G

generations() (Scheduler method) get() (EventStore method) (InputCollection method) (Return method) get_context() (TubeRunner method)

get_entrypoint_sources() (in module noob.config) get_extra_sources() (in module noob.config) get_node_params() (InputCollection method) get_ready() (Scheduler method) get_sources() (Scheduler method)

H

has_cycle() (Scheduler method) has_input (NodeRunner property)

has_return (Tube property) HEADER_FIELDS (ConfigYAMLMixin attribute)

I

id (Asset attribute) (AssetSpecification attribute) (Event attribute) (InputSpecification attribute) (MetaEvent attribute) (Node attribute) (NodeSpecification attribute) identify (MessageType attribute) identify() (NodeRunner method) IdentifyValue (class in noob.network.message) in_edges() (Tube method) inbox (AnnounceValue attribute) increment() (in module noob.testing.nodes) init (MessageType attribute) init() (Asset method) (CommandNode method) (InitCounter method) (Initializer method) (Node method) (NodeRunner method) (State method) (SynchronousRunner method) (TubeNode method) (TubeRunner method) (WrapClassAsset method) (WrapFuncAsset method) (ZMQRunner method)

init_context() (State method) init_logger() (in module noob.logging) init_node() (NodeRunner method) initialized (ZMQRunner property) inject_context() (TubeRunner method) input (ProcessValue attribute) (Tube attribute) (TubeSpecification attribute) input_collection (Tube attribute) input_party() (in module noob.testing.nodes) INPUT_PATTERN (InputCollection attribute) input_present() (Tube method) InputError InputMissingError InputScope (class in noob.input) InputWarning instance (WrapClassNode attribute) is_active() (Scheduler method) is_optional() (in module noob.introspection) is_union() (in module noob.introspection) iscoroutinefunction_partial() (in module noob.utils) iter() (EventStore method) (TubeRunner method) (ZMQRunner method)

J

jump() (in module noob.testing.nodes)

L

letter_source() (in module noob.testing.nodes) level (LogConfig attribute) level_file (LogConfig attribute) level_stdout (LogConfig attribute) limit (CountSource attribute) (UnannotatedGenerator attribute)

logger (Scheduler attribute) logs (Config attribute) long_add() (in module noob.testing.nodes) loop (EventloopMixin property)

M

max_iter_loops (TubeRunner attribute) MessageType (class in noob.network.message) META_SIGNAL (in module noob.const) MetaEvent (class in noob.event) MetaEventType (class in noob.event) MetaSignal (class in noob.event) model_post_init() (CountSource method) (Gather method) (InitCounter method) (InputCollection method) (Map method) (Multiply method) (Node method) (Return method) (Scheduler method) (Tube method) (TubeNode method) (UnannotatedGenerator method) (WrapClassNode method) (WrapFuncNode method) module noob.asset noob.config noob.const noob.event noob.exceptions noob.input noob.introspection noob.logging noob.network.loop noob.network.message noob.node noob.node.base noob.node.gather noob.node.map noob.node.return_ noob.node.spec noob.node.tube noob.runner.base noob.runner.sync noob.runner.zmq noob.scheduler noob.state noob.store noob.testing.assets noob.testing.nodes noob.tube noob.types noob.utils noob.yaml

multi_words_source() (in module noob.testing.nodes) multiply() (in module noob.testing.nodes)

N

n (Gather attribute) Name (class in noob.types) name (Name attribute) (Signal attribute) (Slot attribute) no_file_on_rtd() (LogConfig class method) node structure node (AssetScope attribute) node_id (Event attribute) (IdentifyValue attribute) (Message attribute) (MetaEvent attribute) node_is_ready() (Scheduler method) node_procs (ZMQRunner attribute) NodeReady (MetaEventType attribute) NodeRunner (class in noob.runner.zmq) nodes (AnnounceValue attribute) (Scheduler attribute) (Tube attribute) (TubeSpecification attribute) NodeStatus (class in noob.network.message) NoEvent (MetaSignal attribute) noob.asset module noob.config module noob.const module noob.event module noob.exceptions module noob.input module noob.introspection module noob.logging module noob.network.loop module noob.network.message module noob.node module

noob.node.base module noob.node.gather module noob.node.map module noob.node.return_ module noob.node.spec module noob.node.tube module noob.runner.base module noob.runner.sync module noob.runner.zmq module noob.scheduler module noob.state module noob.store module noob.testing.assets module noob.testing.nodes module noob.tube module noob.types module noob.utils module noob.yaml module noob_id (ConfigYAMLMixin attribute) noob_model (ConfigYAMLMixin attribute) noob_version (ConfigYAMLMixin attribute) NoobError NoobWarning NotAddedError NotOutYetError Now (class in noob.testing.nodes) number_to_letter() (in module noob.testing.nodes) NumberToLetterCls (class in noob.testing.nodes)

O

obj (Asset attribute) (Initializer attribute) (WrapClassAsset attribute) on_announce() (NodeRunner method) on_deinit() (NodeRunner method) on_event() (NodeRunner method) (ZMQRunner method) on_identify() (CommandNode method) on_inbox() (NodeRunner method) on_process() (NodeRunner method)

on_router() (CommandNode method) (ZMQRunner method) on_start() (NodeRunner method) on_status() (CommandNode method) on_stop() (NodeRunner method) only_one_return() (Tube class method) (TubeSpecification class method) out_edges() (Tube method) outbox (IdentifyValue attribute) outbox_address (NodeRunner property)

P

params (Asset attribute) (AssetSpecification attribute) (NodeSpecification attribute) (WrapClassNode attribute) (WrapFuncNode attribute) passthrough() (in module noob.testing.nodes) ping (MessageType attribute) ping() (CommandNode method) print() (Now method) process (AssetScope attribute) (InputScope attribute) (MessageType attribute) process() (CommandNode method) (CountSource method) (CountSourceDecor method) (Gather method) (InitCounter method) (Map method) (Multiply method) (Node method) (NumberToLetterCls method) (Return method) (StatefulMultiply method) (SynchronousRunner method) (TubeNode method) (TubeRunner method) (UnannotatedGenerator method) (VolumeProcess method) (ZMQRunner method)

process_method() (in module noob.node.base) ProcessValue (class in noob.network.message) pub_address (CommandNode property) publish_events() (NodeRunner method) PythonIdentifier (in module noob.types)

Q

quit_timeout (ZMQRunner attribute)

R

ready (NodeStatus attribute) register_socket() (EventloopMixin method) repeat() (in module noob.testing.nodes) represent_path() (YamlRepresenter method) required (Edge attribute) (Slot attribute) RESERVED_IDS (in module noob.const) resolve_python_identifier() (in module noob.utils) rewind() (in module noob.testing.nodes) router_address (CommandNode property) run() (CommandNode method) (NodeRunner class method) (TubeRunner method) (ZMQRunner method)

runner (AssetScope attribute) (RunnerContext attribute) runner_id (TubeRunner property) RunnerContext (class in noob.types) RunnerError running (NodeStatus attribute) (SynchronousRunner property) (TubeRunner property) (ZMQRunner property)

S

scheduler (Tube attribute) SchedulerError scope (Asset attribute) (AssetSpecification attribute) (InputSpecification attribute) scope_to_assets (State attribute) send() (counter method) set_default_statefulness() (WrapFuncNode class method) settings_customise_sources() (Config class method) signal (Event attribute) (MetaEvent attribute) signals (IdentifyValue attribute) (Node property) slot slots (IdentifyValue attribute) (Node property) slots_unique() (NodeSpecification class method) sockets (EventloopMixin property) source_node (Edge attribute) source_nodes (Scheduler attribute) source_signal (Edge attribute) sources_finished() (Scheduler method) spec (Asset attribute) (Node attribute)

SPECIAL_NODES (in module noob.node) specs (InputCollection attribute) split_args_kwargs() (EventStore static method) sporadic_word() (in module noob.testing.nodes) start (CountSource attribute) (MessageType attribute) (UnannotatedGenerator attribute) start() (CommandNode method) state (Tube attribute) stateful (Node attribute) (NodeSpecification attribute) (WrapFuncNode attribute) StatefulMultiply (class in noob.testing.nodes) status (IdentifyValue attribute) (MessageType attribute) (NodeRunner property) stop (MessageType attribute) stop() (CommandNode method) (ZMQRunner method) stopped (NodeStatus attribute) store (TubeRunner attribute) (ZMQRunner attribute) stored_at (Asset attribute) StoreError SynchronousRunner (class in noob.runner.sync)

T

target_node (Edge attribute) target_slot (Edge attribute) throw() (counter method) timestamp (Event attribute) (Message attribute) (MetaEvent attribute) tmp_dir (Config attribute) to_bytes() (Message method) to_exception() (ErrorMsg method) to_yaml() (YAMLMixin method) to_yamls() (YAMLMixin method) traceback (ErrorValue attribute) transform_events() (EventStore static method) tube (InputScope attribute) (RunnerContext attribute) (TubeNode attribute) (TubeRunner attribute) tube_id (Tube attribute)

tube_spec (TubeNode property) TubeClassicEdition (class in noob.tube) TubeError TubeRunner (class in noob.runner.base) type_ (AnnounceMsg attribute) (AssetSpecification attribute) (DeinitMsg attribute) (ErrorMsg attribute) (EventMsg attribute) (IdentifyMsg attribute) (InitMsg attribute) (InputSpecification attribute) (Message attribute) (NodeSpecification attribute) (PingMsg attribute) (ProcessMsg attribute) (Signal attribute) (StartMsg attribute) (StatusMsg attribute) (StopMsg attribute)

U

unwrap() (in module noob.introspection) unwrap_annotated() (in module noob.introspection) unwrap_optional() (in module noob.introspection) update() (Asset method) (Scheduler method) (State method)

update_graph() (NodeRunner method) update_status() (NodeRunner method) uppercase_levels() (LogConfig class method) user_dir (Config attribute)

V

valid_config_id() (in module noob.types) validate_depends() (AssetSpecification method) validate_input() (InputCollection method) value (AnnounceMsg attribute) (DeinitMsg attribute) (ErrorMsg attribute) (Event attribute) (EventMsg attribute) (IdentifyMsg attribute) (InitMsg attribute) (Message attribute) (MetaEvent attribute) (PingMsg attribute) (ProcessMsg attribute) (StartMsg attribute) (StatusMsg attribute) (StopMsg attribute)

Volume (class in noob.testing.nodes) volume() (Volume method) VolumeProcess (class in noob.testing.nodes)

W

waiting (NodeStatus attribute) width (LogConfig attribute)

word_counts() (in module noob.testing.nodes) word_source() (in module noob.testing.nodes)

Y

yaml_peek() (in module noob.yaml) yaml_representers (YamlRepresenter attribute)

YAMLMixin (class in noob.yaml) YamlRepresenter (class in noob.yaml)

Z

zip_iter() (in module noob.testing.nodes)

ZMQRunner (class in noob.runner.zmq)