Index

A

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

announce() (CommandNode method) AnnounceValue (class in noob.network.message) array_add_to_left() (in module noob.testing.nodes) assets (State attribute) (StateSpecification attribute) (TubeSpecification attribute) AssetScope (class in noob.asset) await_epoch() (Scheduler method) await_inputs() (NodeRunner method) await_node() (Scheduler method) await_ready() (CommandNode method)

C

cancel() (Scheduler method) chain (InputCollection property) clear() (EventStore method) (State method) closed (NodeStatus attribute) cls (WrapClassAsset attribute) (WrapClassNode attribute) collect() (EventStore method) (InputCollection method) (State method) collect_events() (EventStore method) collect_input() (TubeRunner 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 (EventStore attribute) CountSourceDecor (class in noob.testing.nodes) create_dir() (Config class method) (LogConfig class method)

D

db_connection() (in module noob.testing.assets) deinit() (Asset method) (Node method) (NodeRunner method) (SynchronousRunner method) (TubeNode method) (TubeRunner method) (WrapClassAsset method) (WrapClassNode method) (WrapFuncAsset method) (ZMQRunner method) dependencies_exist() (TubeSpecification method) DependencyIdentifier (in module noob.types)

depends (AssetSpecification attribute) (NodeRunner property) (NodeSpecification attribute) DependsType (in module noob.node.spec) 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) 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) ExtraInputError ExtraInputWarning

F

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

get() (EventStore method) (InputCollection method) (Return method) (State 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

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) init() (Asset method) (Node method) (NodeRunner method) (SynchronousRunner method) (TubeNode method) (TubeRunner method) (WrapClassAsset method) (WrapFuncAsset method) (ZMQRunner method)

init_logger() (in module noob.logging) init_node() (NodeRunner method) inject_context() (TubeRunner method) input (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) iter() (TubeRunner method)

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) 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) (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 Now (class in noob.testing.nodes)

O

obj (Asset attribute) (WrapClassAsset attribute) on_announce() (NodeRunner method) on_dealer() (NodeRunner method) on_event() (NodeRunner method) (ZMQRunner method) on_identify() (CommandNode method) on_inbox() (CommandNode method) (NodeRunner method)

on_process() (NodeRunner method) on_router() (CommandNode method) (ZMQRunner 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) print() (Now method) process (AssetScope attribute) (InputScope attribute) (MessageType attribute) process() (CommandNode method) (CountSource method) (CountSourceDecor method) (Gather method) (Map method) (Multiply method) (Node method) (Return method) (SynchronousRunner method) (TubeNode method) (TubeRunner method) (UnannotatedGenerator method) (VolumeProcess method) (ZMQRunner method)

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

Q

quit_timeout (ZMQRunner attribute)

R

read_db() (in module noob.testing.nodes) ready (NodeStatus attribute) repeat() (in module noob.testing.nodes) represent_path() (YamlDumper method) required (Edge attribute) (Slot attribute) RESERVED_IDS (in module noob.const) resolve_python_identifier() (in module noob.utils) router_address (CommandNode property) run() (NodeRunner class method) (TubeRunner 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) 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) 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) start_loop() (EventloopMixin method) start_sockets() (NodeRunner method) state (Tube attribute) status (IdentifyValue attribute) (MessageType attribute) (NodeRunner property) stop (MessageType attribute) stop() (CommandNode method) stop_loop() (EventloopMixin method) stopped (NodeStatus attribute) store (TubeRunner attribute) (ZMQRunner attribute) StoreError SynchronousRunner (class in noob.runner.sync)

T

target_node (Edge attribute) target_slot (Edge attribute) timestamp (Event attribute) (Message attribute) (MetaEvent attribute) tmp_dir (Config attribute) to_bytes() (Message 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) (ErrorMsg attribute) (EventMsg attribute) (IdentifyMsg attribute) (InputSpecification attribute) (Message attribute) (NodeSpecification 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)

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_input() (InputCollection method) value (AnnounceMsg attribute) (ErrorMsg attribute) (Event attribute) (EventMsg attribute) (IdentifyMsg attribute) (Message attribute) (MetaEvent 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)

X

xarray_asset() (in module noob.testing.assets)

Y

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

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

Z

ZMQRunner (class in noob.runner.zmq)