Index

_

__determine_multiprocess_mode_existence() (decisionengine.framework.util.metrics.Gauge method) __insert() (decisionengine.framework.dataspace.datablock.DataBlock method) __update() (decisionengine.framework.dataspace.datablock.DataBlock method) _abc_impl (decisionengine.framework.config.ValidConfig.ValidConfig attribute) (decisionengine.framework.dataspace.datablock.Header attribute) (decisionengine.framework.dataspace.datablock.Metadata attribute) (decisionengine.framework.dataspace.datasource.DataSource attribute) (decisionengine.framework.dataspace.datasources.null.NullDataSource attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS attribute) (decisionengine.framework.util.metrics.Counter attribute) (decisionengine.framework.util.metrics.Gauge attribute) (decisionengine.framework.util.metrics.Histogram attribute) (decisionengine.framework.util.metrics.Summary attribute) _asdict() (decisionengine.framework.taskmanager.PublisherStatus.PublisherState method) _channel_config_dir() (in module decisionengine.framework.config.tests.test_config) _channel_preamble() (in module decisionengine.framework.engine.DecisionEngine) _check_keys() (in module decisionengine.framework.config.ChannelConfigHandler) _check_metrics_env() (in module decisionengine.framework.engine.DecisionEngine) _check_override() (in module decisionengine.framework.engine.tests.test_startup) _config_from_file() (in module decisionengine.framework.config.ValidConfig) _consumed_products() (in module decisionengine.framework.taskmanager.module_graph) _consumes (decisionengine.framework.modules.Publisher.Publisher attribute) (decisionengine.framework.modules.Transform.Transform attribute) (decisionengine.framework.tests.ABTransform.ABTransform attribute) (decisionengine.framework.tests.BATransform.BATransform attribute) (decisionengine.framework.tests.ErringPublisher.ErringPublisher attribute) (decisionengine.framework.tests.FailingPublisher.FailingPublisher attribute) (decisionengine.framework.tests.PublisherNOP.PublisherNOP attribute) (decisionengine.framework.tests.TransformNOP.TransformNOP attribute) _consumes_not_subset() (in module decisionengine.framework.tests.test_start_with_bad_channels) _create_de_server() (in module decisionengine.framework.engine.DecisionEngine) _create_facts_dataframe() (decisionengine.framework.logicengine.LogicEngine.LogicEngine method) _create_module_instance() (in module decisionengine.framework.taskmanager.module_graph) _dataframe_to_column_names() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) _dataframe_to_csv() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) _dataframe_to_json() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) _dataframe_to_table() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) _dataframe_to_vertical_tables() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) _DEFAULT_MULTIPROC_MODE (decisionengine.framework.util.metrics.Gauge attribute) _derived_class() (in module decisionengine.framework.util.subclasses) _dispatch() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) _expected_acquire_result() (in module decisionengine.framework.tests.ModuleProgramOptions) _expected_circularity() (in module decisionengine.framework.tests.test_start_with_bad_channels) _expected_config_template() (in module decisionengine.framework.tests.ModuleProgramOptions) _expected_config_template_with_comments() (in module decisionengine.framework.tests.ModuleProgramOptions) _expected_help() (in module decisionengine.framework.tests.ModuleProgramOptions) _expected_source_help() (in module decisionengine.framework.tests.ModuleProgramOptions) _field_defaults (decisionengine.framework.taskmanager.PublisherStatus.PublisherState attribute) _fields (decisionengine.framework.taskmanager.PublisherStatus.PublisherState attribute) _find_only_one_subclass() (in module decisionengine.framework.taskmanager.module_graph) _get_de_conf_manager() (in module decisionengine.framework.engine.DecisionEngine) _get_global_config() (in module decisionengine.framework.engine.DecisionEngine)

_global_config_file() (in module decisionengine.framework.config.tests.test_config) _initial_start_channels() (in module decisionengine.framework.engine.DecisionEngine) _instances (decisionengine.framework.util.singleton.ScopedSingleton attribute) (decisionengine.framework.util.singleton.Singleton attribute) _listen() (decisionengine.framework.taskmanager.LatestMessages.LatestMessages method) _load_channel() (decisionengine.framework.config.ChannelConfigHandler.ChannelConfigHandler method) _make() (decisionengine.framework.taskmanager.PublisherStatus.PublisherState class method) _make_de_logger() (in module decisionengine.framework.config.ChannelConfigHandler) _make_workers_for() (in module decisionengine.framework.taskmanager.module_graph) _missing_consumes() (in module decisionengine.framework.tests.test_start_with_bad_channels) _missing_produces() (in module decisionengine.framework.tests.test_start_with_bad_channels) _normalize() (in module decisionengine.framework.tests.ModuleProgramOptions) _par_default() (in module decisionengine.framework.modules.describe) _par_type() (in module decisionengine.framework.modules.describe) _print_comment() (in module decisionengine.framework.modules.print_description) _print_type() (in module decisionengine.framework.modules.print_description) _print_value() (in module decisionengine.framework.modules.print_description) _produced_products() (in module decisionengine.framework.taskmanager.module_graph) _produces (decisionengine.framework.modules.Source.Source attribute) (decisionengine.framework.modules.Transform.Transform attribute) (decisionengine.framework.tests.ABTransform.ABTransform attribute) (decisionengine.framework.tests.BATransform.BATransform attribute) (decisionengine.framework.tests.ErrorOnAcquire.ErrorOnAcquire attribute) (decisionengine.framework.tests.IntSource.IntSource attribute) (decisionengine.framework.tests.SourceNOP.SourceNOP attribute) (decisionengine.framework.tests.SourceWithSampleConfigNOP.SourceWithSampleConfigNOP attribute) (decisionengine.framework.tests.TransformNOP.TransformNOP attribute) _queue_name_and_type() (in module decisionengine.framework.engine.DecisionEngine) _reaper_loop() (decisionengine.framework.dataspace.maintain.Reaper method) _receive() (decisionengine.framework.engine.ClientMessageReceiver.ClientMessageReceiver method) _redis_server_running() (in module decisionengine.framework.engine.tests.conftest) _replace() (decisionengine.framework.taskmanager.PublisherStatus.PublisherState method) _requests_in_flight() (in module decisionengine.framework.engine.DecisionEngine) _run_as_main() (in module decisionengine.framework.tests.ModuleProgramOptions) _sa_class_manager (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Dataproduct attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Schema attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) _sa_registry (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Base attribute) _setitem() (decisionengine.framework.dataspace.datablock.DataBlock method) _spec_from_file_name() (in module decisionengine.framework.modules.print_description) _start_de_server() (in module decisionengine.framework.engine.DecisionEngine) _supported_config (decisionengine.framework.modules.EmptySource.EmptySource attribute) (decisionengine.framework.tests.DynamicPublisher.DynamicPublisher attribute) (decisionengine.framework.tests.DynamicSource.DynamicSource attribute) (decisionengine.framework.tests.DynamicTransform.DynamicTransform attribute) (decisionengine.framework.tests.IntSource.IntSource attribute) (decisionengine.framework.tests.SourceWithSampleConfigNOP.SourceWithSampleConfigNOP attribute) (decisionengine.framework.tests.SupportsConfigPublisher.SupportsConfig attribute) (decisionengine.framework.tests.WriteToDisk.WriteToDisk attribute) _verify_redis_server() (in module decisionengine.framework.engine.DecisionEngine) _verify_redis_url() (in module decisionengine.framework.engine.DecisionEngine)

A

ABTransform (class in decisionengine.framework.tests.ABTransform) access() (decisionengine.framework.engine.ChannelWorkers.ChannelWorkers method) (decisionengine.framework.engine.SourceWorkers.SourceWorkers method) accessed_by_another_thread() (decisionengine.framework.engine.ChannelWorkers.ChannelWorkers method) acquire() (decisionengine.framework.modules.EmptySource.EmptySource method) (decisionengine.framework.modules.Source.Source method) (decisionengine.framework.tests.DynamicSource.DynamicSource method) (decisionengine.framework.tests.ErrorOnAcquire.ErrorOnAcquire method) (decisionengine.framework.tests.IntSource.IntSource method) (decisionengine.framework.tests.SourceNOP.SourceNOP method) (decisionengine.framework.tests.SourceWithSampleConfigNOP.SourceWithSampleConfigNOP method)

AcquireWithConfig (class in decisionengine.framework.tests.ModuleProgramOptions) AcquireWithSampleConfig (class in decisionengine.framework.tests.ModuleProgramOptions) ACTIVE (decisionengine.framework.taskmanager.ProcessingState.State attribute) add_engine_pidguard() (in module decisionengine.framework.dataspace.datasources.sqlalchemy_ds.utils) all_subclasses() (in module decisionengine.framework.util.subclasses)

B

Base (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema) BATransform (class in decisionengine.framework.tests.BATransform)

block_while() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) BooleanExpression (class in decisionengine.framework.logicengine.BooleanExpression) BOOT (decisionengine.framework.taskmanager.ProcessingState.State attribute)

C

channel_config_dir() (in module decisionengine.framework.config.policies) channel_workers() (in module decisionengine.framework.taskmanager.module_graph) ChannelConfigHandler (class in decisionengine.framework.config.ChannelConfigHandler) ChannelWorker (class in decisionengine.framework.engine.ChannelWorkers) ChannelWorkers (class in decisionengine.framework.engine.ChannelWorkers) ChannelWorkers.Access (class in decisionengine.framework.engine.ChannelWorkers) Clean (decisionengine.framework.engine.DecisionEngine.StopState attribute) ClientMessageReceiver (class in decisionengine.framework.engine.ClientMessageReceiver) clone_model() (in module decisionengine.framework.dataspace.datasources.sqlalchemy_ds.utils) close() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) command_for_args() (in module decisionengine.framework.engine.de_client) (in module decisionengine.framework.engine.de_query_tool) compress() (in module decisionengine.framework.dataspace.datablock) config() (in module decisionengine.framework.config.tests.test_de_std) (in module decisionengine.framework.dataspace.tests.test_Reaper) ConfigTemplate (class in decisionengine.framework.tests.ModuleProgramOptions) configure_listener() (decisionengine.framework.modules.QueueLogger.QueueLogger method) configure_logging() (in module decisionengine.framework.modules.de_logger) connect() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method)

console_scripts_main() (in module decisionengine.framework.engine.de_client) (in module decisionengine.framework.engine.de_query_tool) (in module decisionengine.framework.util.logparser) consume() (decisionengine.framework.taskmanager.LatestMessages.LatestMessages method) consumes() (decisionengine.framework.logicengine.LogicEngine.LogicEngine method) (in module decisionengine.framework.modules.Module) (in module decisionengine.framework.modules.Publisher) (in module decisionengine.framework.modules.Transform) Countdown (class in decisionengine.framework.util.countdown) Counter (class in decisionengine.framework.util.metrics) create_channel() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) create_parser() (in module decisionengine.framework.engine.de_client) (in module decisionengine.framework.engine.de_query_tool) (in module decisionengine.framework.util.logparser) create_tables() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) create_time (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) creator (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute)

D

data_block_put() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) DataBlock (class in decisionengine.framework.dataspace.datablock) Dataproduct (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema) dataproduct_table (decisionengine.framework.dataspace.datasource.DataSource attribute) DataSource (class in decisionengine.framework.dataspace.datasource) datasource() (in module decisionengine.framework.dataspace.datasources.tests.fixtures) (in module decisionengine.framework.dataspace.tests.fixtures) DataSpace (class in decisionengine.framework.dataspace.dataspace) dataspace() (in module decisionengine.framework.dataspace.tests.fixtures) DataSpaceConfigurationError DataSpaceConnectionError DataSpaceError DataSpaceExistsError datestamp (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) decision_cycle() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) decisionengine module DecisionEngine (class in decisionengine.framework.engine.DecisionEngine) decisionengine.framework module decisionengine.framework.about module decisionengine.framework.config module decisionengine.framework.config.ChannelConfigHandler module decisionengine.framework.config.policies module decisionengine.framework.config.tests module decisionengine.framework.config.tests.test_config module decisionengine.framework.config.tests.test_de_std module decisionengine.framework.config.tests.test_policies module decisionengine.framework.config.ValidConfig module decisionengine.framework.dataspace module decisionengine.framework.dataspace.datablock module decisionengine.framework.dataspace.datasource module decisionengine.framework.dataspace.datasources module decisionengine.framework.dataspace.datasources.null module decisionengine.framework.dataspace.datasources.sqlalchemy_ds module decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api module decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema module decisionengine.framework.dataspace.datasources.sqlalchemy_ds.utils module decisionengine.framework.dataspace.datasources.tests module decisionengine.framework.dataspace.datasources.tests.fixtures module decisionengine.framework.dataspace.datasources.tests.test_datasource_api module decisionengine.framework.dataspace.dataspace module decisionengine.framework.dataspace.maintain module decisionengine.framework.dataspace.tests module decisionengine.framework.dataspace.tests.fixtures module decisionengine.framework.dataspace.tests.test_datablock module decisionengine.framework.dataspace.tests.test_datablock_zlib module decisionengine.framework.dataspace.tests.test_datasource module decisionengine.framework.dataspace.tests.test_dataspace module decisionengine.framework.dataspace.tests.test_Reaper module decisionengine.framework.engine module decisionengine.framework.engine.ChannelWorkers module decisionengine.framework.engine.ClientMessageReceiver module decisionengine.framework.engine.de_client module decisionengine.framework.engine.de_query_tool module decisionengine.framework.engine.DecisionEngine module decisionengine.framework.engine.SourceWorkers module decisionengine.framework.engine.tests module decisionengine.framework.engine.tests.conftest module decisionengine.framework.engine.tests.fixtures module decisionengine.framework.engine.tests.test_ChannelWorkers module decisionengine.framework.engine.tests.test_client_only module decisionengine.framework.engine.tests.test_query_tool_only module decisionengine.framework.engine.tests.test_SourceWorkers module decisionengine.framework.engine.tests.test_startup module decisionengine.framework.engine.tests.test_verify_redis_server module decisionengine.framework.logicengine module decisionengine.framework.logicengine.BooleanExpression module decisionengine.framework.logicengine.FactLookup module decisionengine.framework.logicengine.LogicEngine module decisionengine.framework.logicengine.Rule module decisionengine.framework.logicengine.RuleEngine module decisionengine.framework.logicengine.tests module decisionengine.framework.logicengine.tests.test_bool_function_name module decisionengine.framework.logicengine.tests.test_cascaded_rules module decisionengine.framework.logicengine.tests.test_construction module decisionengine.framework.logicengine.tests.test_duplicate_fact_names module decisionengine.framework.logicengine.tests.test_facts module decisionengine.framework.logicengine.tests.test_fail_on_error module decisionengine.framework.logicengine.tests.test_pandas_fact module decisionengine.framework.logicengine.tests.test_rule_with_negated_fact module decisionengine.framework.logicengine.tests.test_simple_configuration module decisionengine.framework.modules module decisionengine.framework.modules.de_logger module decisionengine.framework.modules.describe module decisionengine.framework.modules.EmptySource module decisionengine.framework.modules.logging_configDict module decisionengine.framework.modules.Module module decisionengine.framework.modules.print_description module decisionengine.framework.modules.Publisher module decisionengine.framework.modules.QueueLogger module decisionengine.framework.modules.Source module decisionengine.framework.modules.tests module

decisionengine.framework.modules.tests.test_de_logger module decisionengine.framework.modules.tests.test_EmptySource module decisionengine.framework.modules.tests.test_Module module decisionengine.framework.modules.tests.test_module_decorators module decisionengine.framework.modules.tests.test_Publisher module decisionengine.framework.modules.tests.test_QueueLogger module decisionengine.framework.modules.tests.test_Source module decisionengine.framework.modules.tests.test_Transform module decisionengine.framework.modules.tests.test_translate_product_name module decisionengine.framework.modules.Transform module decisionengine.framework.modules.translate_product_name module decisionengine.framework.taskmanager module decisionengine.framework.taskmanager.LatestMessages module decisionengine.framework.taskmanager.module_graph module decisionengine.framework.taskmanager.ProcessingState module decisionengine.framework.taskmanager.PublisherStatus module decisionengine.framework.taskmanager.SourceProductCache module decisionengine.framework.taskmanager.TaskManager module decisionengine.framework.tests module decisionengine.framework.tests.ABTransform module decisionengine.framework.tests.BATransform module decisionengine.framework.tests.DynamicPublisher module decisionengine.framework.tests.DynamicSource module decisionengine.framework.tests.DynamicTransform module decisionengine.framework.tests.ErringPublisher module decisionengine.framework.tests.ErrorOnAcquire module decisionengine.framework.tests.FailingPublisher module decisionengine.framework.tests.fixtures module decisionengine.framework.tests.IntSource module decisionengine.framework.tests.ModuleProgramOptions module decisionengine.framework.tests.PublisherNOP module decisionengine.framework.tests.PublisherWithMissingConsumes module decisionengine.framework.tests.SourceAlias module decisionengine.framework.tests.SourceNOP module decisionengine.framework.tests.SourceWithMissingProduces module decisionengine.framework.tests.SourceWithSampleConfigNOP module decisionengine.framework.tests.SupportsConfigPublisher module decisionengine.framework.tests.test_client_errors module decisionengine.framework.tests.test_client_server module decisionengine.framework.tests.test_combined_channels module decisionengine.framework.tests.test_defaults module decisionengine.framework.tests.test_dynamic_test_modules module decisionengine.framework.tests.test_empty_config module decisionengine.framework.tests.test_error_on_acquire module decisionengine.framework.tests.test_module_program_options module decisionengine.framework.tests.test_publisher_status module decisionengine.framework.tests.test_publisher_status_board module decisionengine.framework.tests.test_query_tool_server module decisionengine.framework.tests.test_reaper module decisionengine.framework.tests.test_same_source_types module decisionengine.framework.tests.test_sample_config module decisionengine.framework.tests.test_shared_sources module decisionengine.framework.tests.test_start_with_bad_channels module decisionengine.framework.tests.test_status_during_startup module decisionengine.framework.tests.TransformNOP module decisionengine.framework.tests.TransformWithMissingProducesConsumes module decisionengine.framework.tests.WriteToDisk module decisionengine.framework.util module decisionengine.framework.util.countdown module decisionengine.framework.util.fs module decisionengine.framework.util.logparser module decisionengine.framework.util.metrics module decisionengine.framework.util.reaper module decisionengine.framework.util.redis_stats module decisionengine.framework.util.singleton module decisionengine.framework.util.sockets module decisionengine.framework.util.subclasses module decisionengine.framework.version module decisionengine.tests module decisionengine.tests.test_framework_package module decompress() (in module decisionengine.framework.dataspace.datablock) default_data_lifetime (decisionengine.framework.dataspace.datablock.Header attribute) delete() (decisionengine.framework.dataspace.dataspace.DataSpace method) delete_data_older_than() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) Describe (class in decisionengine.framework.tests.ModuleProgramOptions) describe() (in module decisionengine.framework.modules.Publisher) (in module decisionengine.framework.modules.Source) (in module decisionengine.framework.modules.Transform) DescribeAlias (class in decisionengine.framework.tests.ModuleProgramOptions) DEServer() (in module decisionengine.framework.engine.tests.fixtures) (in module decisionengine.framework.tests.fixtures) detach() (decisionengine.framework.engine.SourceWorkers.SourceWorkers method) display_metrics() (in module decisionengine.framework.util.metrics) dump() (decisionengine.framework.config.ValidConfig.ValidConfig method) duplicate() (decisionengine.framework.dataspace.datablock.DataBlock method) duplicate_datablock() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) duration (decisionengine.framework.taskmanager.PublisherStatus.PublisherState attribute) DynamicPublisher (class in decisionengine.framework.tests.DynamicPublisher) DynamicSource (class in decisionengine.framework.tests.DynamicSource) DynamicTransform (class in decisionengine.framework.tests.DynamicTransform)

E

EmptySource (class in decisionengine.framework.modules.EmptySource) enabled (decisionengine.framework.taskmanager.PublisherStatus.PublisherState attribute) ensure_no_circularities() (in module decisionengine.framework.taskmanager.module_graph) ErringPublisher (class in decisionengine.framework.tests.ErringPublisher) ERROR (decisionengine.framework.taskmanager.ProcessingState.State attribute) ErrorOnAcquire (class in decisionengine.framework.tests.ErrorOnAcquire) evaluate() (decisionengine.framework.logicengine.BooleanExpression.BooleanExpression method) (decisionengine.framework.logicengine.LogicEngine.LogicEngine method) (decisionengine.framework.logicengine.Rule.Rule method)

evaluate_facts() (decisionengine.framework.logicengine.LogicEngine.LogicEngine method) execute() (decisionengine.framework.engine.ClientMessageReceiver.ClientMessageReceiver method) (decisionengine.framework.logicengine.RuleEngine.RuleEngine method) execute_command_from_args() (in module decisionengine.framework.util.logparser) expiration_time (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute)

F

FactLookup (class in decisionengine.framework.logicengine.FactLookup) FailingPublisher (class in decisionengine.framework.tests.FailingPublisher) fake_redis_server() (in module decisionengine.framework.engine.tests.test_verify_redis_server)

files_with_extensions() (in module decisionengine.framework.util.fs) format_logger() (decisionengine.framework.modules.QueueLogger.QueueLogger method) function_name_from_call() (in module decisionengine.framework.logicengine.BooleanExpression)

G

Gauge (class in decisionengine.framework.util.metrics) generation_id (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Dataproduct attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) generation_time (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) get() (decisionengine.framework.dataspace.datablock.DataBlock method) (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) get_channels() (decisionengine.framework.config.ChannelConfigHandler.ChannelConfigHandler method) get_consumes() (decisionengine.framework.engine.ChannelWorkers.ChannelWorker method) (decisionengine.framework.taskmanager.TaskManager.TaskManager method) get_data_block() (decisionengine.framework.modules.Module.Module method) get_datablock() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_dataproduct() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_dataproducts() (decisionengine.framework.dataspace.datablock.DataBlock method) (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_header() (decisionengine.framework.dataspace.datablock.DataBlock method) (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_last_generation_id() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_logger() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) (in module decisionengine.framework.modules.de_logger)

get_loglevel() (decisionengine.framework.engine.SourceWorkers.SourceWorker method) (decisionengine.framework.taskmanager.TaskManager.TaskManager method) get_metadata() (decisionengine.framework.dataspace.datablock.DataBlock method) (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_parameters() (decisionengine.framework.modules.Module.Module method) get_produces() (decisionengine.framework.engine.ChannelWorkers.ChannelWorker method) (decisionengine.framework.taskmanager.TaskManager.TaskManager method) get_queue_logger() (in module decisionengine.framework.modules.de_logger) get_random_port() (in module decisionengine.framework.util.sockets) get_schema() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) get_state() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) get_state_name() (decisionengine.framework.engine.ChannelWorkers.ChannelWorker method) (decisionengine.framework.taskmanager.TaskManager.TaskManager method) get_state_value() (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) (decisionengine.framework.taskmanager.TaskManager.TaskManager method) get_taskmanager() (decisionengine.framework.dataspace.datablock.DataBlock method) (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_taskmanagers() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) get_unguarded() (decisionengine.framework.engine.ChannelWorkers.ChannelWorkers method) (decisionengine.framework.engine.SourceWorkers.SourceWorkers method) global_config() (in module decisionengine.framework.engine.tests.test_ChannelWorkers) (in module decisionengine.framework.engine.tests.test_SourceWorkers) global_config_dir() (in module decisionengine.framework.config.policies) global_config_file() (in module decisionengine.framework.config.policies)

H

handler_setup() (in module decisionengine.framework.modules.tests.test_QueueLogger) has_value() (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) Header (class in decisionengine.framework.dataspace.datablock) (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema)

header_table (decisionengine.framework.dataspace.datasource.DataSource attribute) Help (class in decisionengine.framework.tests.ModuleProgramOptions) Histogram (class in decisionengine.framework.util.metrics)

I

id (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Dataproduct attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) IDLE (decisionengine.framework.taskmanager.ProcessingState.State attribute) inactive() (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) initialize_q() (decisionengine.framework.modules.QueueLogger.QueueLogger method) insert() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method)

IntSource (class in decisionengine.framework.tests.IntSource) InvalidMetadataError is_enabled() (decisionengine.framework.taskmanager.PublisherStatus.PublisherStatus method) is_expired() (decisionengine.framework.dataspace.datablock.DataBlock method) is_valid() (decisionengine.framework.dataspace.datablock.Header method)

K

key (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Dataproduct attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute)

keys() (decisionengine.framework.dataspace.datablock.DataBlock method)

L

LatestMessages (class in decisionengine.framework.taskmanager.LatestMessages) load() (in module decisionengine.framework.config.tests.test_config) load_all_channels() (decisionengine.framework.config.ChannelConfigHandler.ChannelConfigHandler method) load_channel() (decisionengine.framework.config.ChannelConfigHandler.ChannelConfigHandler method) load_sample_data_into_datasource() (in module decisionengine.framework.dataspace.tests.fixtures)

lock (decisionengine.framework.taskmanager.ProcessingState.ProcessingState property) log_setup() (in module decisionengine.framework.modules.tests.test_de_logger) (in module decisionengine.framework.modules.tests.test_QueueLogger) logic_engine_with_fact() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) LogicEngine (class in decisionengine.framework.logicengine.LogicEngine) LogicError

M

main() (in module decisionengine.framework.engine.de_client) (in module decisionengine.framework.engine.de_query_tool) (in module decisionengine.framework.engine.DecisionEngine) (in module decisionengine.framework.util.logparser) (in module decisionengine.framework.util.reaper) main_wrapper() (in module decisionengine.framework.modules.describe) make_db() (in module decisionengine.framework.logicengine.tests.test_facts) mark_demented() (decisionengine.framework.dataspace.dataspace.DataSpace method) mark_expired() (decisionengine.framework.dataspace.datablock.DataBlock method) (decisionengine.framework.dataspace.dataspace.DataSpace method) matches_constraint() (in module decisionengine.framework.util.logparser) maybe_fail_on_error() (in module decisionengine.framework.logicengine.BooleanExpression) Metadata (class in decisionengine.framework.dataspace.datablock) (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema) metadata (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Base attribute) metadata_table (decisionengine.framework.dataspace.datasource.DataSource attribute) metrics() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) metrics_env_setup() (in module decisionengine.framework.engine.tests.test_startup) MIN_RETENTION_INTERVAL_DAYS (decisionengine.framework.dataspace.maintain.Reaper attribute) MIN_SECONDS_BETWEEN_RUNS (decisionengine.framework.dataspace.maintain.Reaper attribute) missed_update_count (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) mock_data_block() (in module decisionengine.framework.dataspace.datasources.tests.fixtures) module decisionengine decisionengine.framework decisionengine.framework.about decisionengine.framework.config decisionengine.framework.config.ChannelConfigHandler decisionengine.framework.config.policies decisionengine.framework.config.tests decisionengine.framework.config.tests.test_config decisionengine.framework.config.tests.test_de_std decisionengine.framework.config.tests.test_policies decisionengine.framework.config.ValidConfig decisionengine.framework.dataspace decisionengine.framework.dataspace.datablock decisionengine.framework.dataspace.datasource decisionengine.framework.dataspace.datasources decisionengine.framework.dataspace.datasources.null decisionengine.framework.dataspace.datasources.sqlalchemy_ds decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema decisionengine.framework.dataspace.datasources.sqlalchemy_ds.utils decisionengine.framework.dataspace.datasources.tests decisionengine.framework.dataspace.datasources.tests.fixtures decisionengine.framework.dataspace.datasources.tests.test_datasource_api decisionengine.framework.dataspace.dataspace decisionengine.framework.dataspace.maintain decisionengine.framework.dataspace.tests decisionengine.framework.dataspace.tests.fixtures decisionengine.framework.dataspace.tests.test_datablock decisionengine.framework.dataspace.tests.test_datablock_zlib decisionengine.framework.dataspace.tests.test_datasource decisionengine.framework.dataspace.tests.test_dataspace decisionengine.framework.dataspace.tests.test_Reaper decisionengine.framework.engine decisionengine.framework.engine.ChannelWorkers decisionengine.framework.engine.ClientMessageReceiver decisionengine.framework.engine.de_client decisionengine.framework.engine.de_query_tool decisionengine.framework.engine.DecisionEngine decisionengine.framework.engine.SourceWorkers decisionengine.framework.engine.tests decisionengine.framework.engine.tests.conftest decisionengine.framework.engine.tests.fixtures decisionengine.framework.engine.tests.test_ChannelWorkers decisionengine.framework.engine.tests.test_client_only decisionengine.framework.engine.tests.test_query_tool_only decisionengine.framework.engine.tests.test_SourceWorkers decisionengine.framework.engine.tests.test_startup decisionengine.framework.engine.tests.test_verify_redis_server decisionengine.framework.logicengine decisionengine.framework.logicengine.BooleanExpression decisionengine.framework.logicengine.FactLookup decisionengine.framework.logicengine.LogicEngine decisionengine.framework.logicengine.Rule decisionengine.framework.logicengine.RuleEngine decisionengine.framework.logicengine.tests decisionengine.framework.logicengine.tests.test_bool_function_name decisionengine.framework.logicengine.tests.test_cascaded_rules decisionengine.framework.logicengine.tests.test_construction decisionengine.framework.logicengine.tests.test_duplicate_fact_names decisionengine.framework.logicengine.tests.test_facts decisionengine.framework.logicengine.tests.test_fail_on_error decisionengine.framework.logicengine.tests.test_pandas_fact decisionengine.framework.logicengine.tests.test_rule_with_negated_fact decisionengine.framework.logicengine.tests.test_simple_configuration decisionengine.framework.modules decisionengine.framework.modules.de_logger decisionengine.framework.modules.describe decisionengine.framework.modules.EmptySource decisionengine.framework.modules.logging_configDict decisionengine.framework.modules.Module decisionengine.framework.modules.print_description decisionengine.framework.modules.Publisher decisionengine.framework.modules.QueueLogger decisionengine.framework.modules.Source decisionengine.framework.modules.tests decisionengine.framework.modules.tests.test_de_logger decisionengine.framework.modules.tests.test_EmptySource decisionengine.framework.modules.tests.test_Module decisionengine.framework.modules.tests.test_module_decorators decisionengine.framework.modules.tests.test_Publisher decisionengine.framework.modules.tests.test_QueueLogger decisionengine.framework.modules.tests.test_Source decisionengine.framework.modules.tests.test_Transform decisionengine.framework.modules.tests.test_translate_product_name decisionengine.framework.modules.Transform decisionengine.framework.modules.translate_product_name decisionengine.framework.taskmanager decisionengine.framework.taskmanager.LatestMessages decisionengine.framework.taskmanager.module_graph decisionengine.framework.taskmanager.ProcessingState decisionengine.framework.taskmanager.PublisherStatus decisionengine.framework.taskmanager.SourceProductCache decisionengine.framework.taskmanager.TaskManager decisionengine.framework.tests decisionengine.framework.tests.ABTransform decisionengine.framework.tests.BATransform decisionengine.framework.tests.DynamicPublisher decisionengine.framework.tests.DynamicSource decisionengine.framework.tests.DynamicTransform decisionengine.framework.tests.ErringPublisher decisionengine.framework.tests.ErrorOnAcquire decisionengine.framework.tests.FailingPublisher decisionengine.framework.tests.fixtures decisionengine.framework.tests.IntSource decisionengine.framework.tests.ModuleProgramOptions decisionengine.framework.tests.PublisherNOP decisionengine.framework.tests.PublisherWithMissingConsumes decisionengine.framework.tests.SourceAlias decisionengine.framework.tests.SourceNOP decisionengine.framework.tests.SourceWithMissingProduces decisionengine.framework.tests.SourceWithSampleConfigNOP decisionengine.framework.tests.SupportsConfigPublisher decisionengine.framework.tests.test_client_errors decisionengine.framework.tests.test_client_server decisionengine.framework.tests.test_combined_channels decisionengine.framework.tests.test_defaults decisionengine.framework.tests.test_dynamic_test_modules decisionengine.framework.tests.test_empty_config decisionengine.framework.tests.test_error_on_acquire decisionengine.framework.tests.test_module_program_options decisionengine.framework.tests.test_publisher_status decisionengine.framework.tests.test_publisher_status_board decisionengine.framework.tests.test_query_tool_server decisionengine.framework.tests.test_reaper decisionengine.framework.tests.test_same_source_types decisionengine.framework.tests.test_sample_config decisionengine.framework.tests.test_shared_sources decisionengine.framework.tests.test_start_with_bad_channels decisionengine.framework.tests.test_status_during_startup decisionengine.framework.tests.TransformNOP decisionengine.framework.tests.TransformWithMissingProducesConsumes decisionengine.framework.tests.WriteToDisk decisionengine.framework.util decisionengine.framework.util.countdown decisionengine.framework.util.fs decisionengine.framework.util.logparser decisionengine.framework.util.metrics decisionengine.framework.util.reaper decisionengine.framework.util.redis_stats decisionengine.framework.util.singleton decisionengine.framework.util.sockets decisionengine.framework.util.subclasses decisionengine.framework.version decisionengine.tests decisionengine.tests.test_framework_package

Module (class in decisionengine.framework.modules.Module) ModuleProgramOptions (class in decisionengine.framework.modules.describe) mydata() (in module decisionengine.framework.logicengine.tests.test_pandas_fact) myengine() (in module decisionengine.framework.logicengine.tests.test_cascaded_rules) (in module decisionengine.framework.logicengine.tests.test_pandas_fact) (in module decisionengine.framework.logicengine.tests.test_rule_with_negated_fact) (in module decisionengine.framework.logicengine.tests.test_simple_configuration)

N

name (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) (decisionengine.framework.engine.tests.test_ChannelWorkers.TaskManager attribute)

NotFound (decisionengine.framework.engine.DecisionEngine.StopState attribute) NullDataSource (class in decisionengine.framework.dataspace.datasources.null)

O

OFFLINE (decisionengine.framework.taskmanager.ProcessingState.State attribute)

orm_as_dict() (in module decisionengine.framework.dataspace.datasources.sqlalchemy_ds.utils)

P

Parameter (class in decisionengine.framework.modules.describe) (class in decisionengine.framework.modules.Publisher) (class in decisionengine.framework.modules.Source) (class in decisionengine.framework.modules.Transform) parse_constraints() (in module decisionengine.framework.util.logparser) parse_program_options() (in module decisionengine.framework.engine.DecisionEngine) passthrough_configuration() (in module decisionengine.framework.logicengine.LogicEngine) PG_DE_DB_WITHOUT_SCHEMA() (in module decisionengine.framework.dataspace.datasources.tests.fixtures) (in module decisionengine.framework.dataspace.tests.fixtures) (in module decisionengine.framework.engine.tests.fixtures) (in module decisionengine.framework.tests.fixtures) PG_PROG() (in module decisionengine.framework.dataspace.datasources.tests.fixtures) (in module decisionengine.framework.dataspace.tests.fixtures) (in module decisionengine.framework.engine.tests.fixtures) (in module decisionengine.framework.tests.fixtures) print_channel_config() (decisionengine.framework.config.ChannelConfigHandler.ChannelConfigHandler method) print_consumes() (in module decisionengine.framework.modules.print_description) print_produces() (in module decisionengine.framework.modules.print_description) print_supported_config() (in module decisionengine.framework.modules.print_description) probably_running() (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) process_args() (decisionengine.framework.modules.describe.ModuleProgramOptions method)

ProcessingState (class in decisionengine.framework.taskmanager.ProcessingState) produces() (decisionengine.framework.logicengine.LogicEngine.LogicEngine method) (in module decisionengine.framework.modules.Module) (in module decisionengine.framework.modules.Source) (in module decisionengine.framework.modules.Transform) ProductRetriever (class in decisionengine.framework.dataspace.datablock) prune() (decisionengine.framework.engine.SourceWorkers.SourceWorkers method) publish() (decisionengine.framework.modules.Publisher.Publisher method) (decisionengine.framework.tests.ErringPublisher.ErringPublisher method) (decisionengine.framework.tests.FailingPublisher.FailingPublisher method) (decisionengine.framework.tests.PublisherNOP.PublisherNOP method) (decisionengine.framework.tests.WriteToDisk.WriteToDisk method) Publisher (class in decisionengine.framework.modules.Publisher) publisher() (decisionengine.framework.tests.DynamicPublisher.DynamicPublisher method) PublisherNOP (class in decisionengine.framework.tests.PublisherNOP) PublisherState (class in decisionengine.framework.taskmanager.PublisherStatus) PublisherStatus (class in decisionengine.framework.taskmanager.PublisherStatus) PublisherStatusBoard (class in decisionengine.framework.taskmanager.PublisherStatus) PublisherWithMissingConsumes (class in decisionengine.framework.tests.PublisherWithMissingConsumes) put() (decisionengine.framework.dataspace.datablock.DataBlock method) pytest_runtest_call() (in module decisionengine.framework.engine.tests.conftest)

Q

queue_logger_setup() (in module decisionengine.framework.modules.tests.test_QueueLogger)

QueueLogger (class in decisionengine.framework.modules.QueueLogger)

R

reap() (decisionengine.framework.dataspace.maintain.Reaper method) Reaper (class in decisionengine.framework.dataspace.maintain) reaper() (in module decisionengine.framework.dataspace.tests.test_Reaper) reaper_start() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) reaper_status() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) reaper_stop() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) record_that_matches() (in module decisionengine.framework.tests.test_shared_sources) redis_stats() (in module decisionengine.framework.util.redis_stats) registry (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Base attribute) remove_all() (decisionengine.framework.engine.SourceWorkers.SourceWorkers method) RequestHandler (class in decisionengine.framework.engine.DecisionEngine) required_keys (decisionengine.framework.dataspace.datablock.Header attribute) (decisionengine.framework.dataspace.datablock.Metadata attribute) reset_connections() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) retention_interval (decisionengine.framework.dataspace.maintain.Reaper property) rm_channel() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_block_while() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_get_channel_log_level() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_get_log_level() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_get_source_log_level() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_kill_channel() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_metrics() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_paths (decisionengine.framework.engine.DecisionEngine.RequestHandler attribute) rpc_ping() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_print_product() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method)

rpc_print_products() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_product_dependencies() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_query_tool() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_queue_status() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_reaper_start() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_reaper_status() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_reaper_stop() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_rm_channel() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_set_channel_log_level() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_set_source_log_level() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_show_config() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_show_de_config() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_start_channel() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_start_channels() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_status() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_stop() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_stop_channel() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) rpc_stop_channels() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) Rule (class in decisionengine.framework.logicengine.Rule) rule_for() (decisionengine.framework.logicengine.FactLookup.FactLookup method) RuleEngine (class in decisionengine.framework.logicengine.RuleEngine) run() (decisionengine.framework.engine.ChannelWorkers.ChannelWorker method) (decisionengine.framework.engine.SourceWorkers.SourceWorker method) run_cycle() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) run_cycles() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) run_logic_engine() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) run_publishers() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) run_transform() (decisionengine.framework.taskmanager.TaskManager.TaskManager method) run_transforms() (decisionengine.framework.taskmanager.TaskManager.TaskManager method)

S

scheduled_create_time (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) Schema (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema) schema (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Schema attribute) schema_id (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Schema attribute) ScopedSingleton (class in decisionengine.framework.util.singleton) ScopedSingletonABC (class in decisionengine.framework.util.singleton) seconds_between_runs (decisionengine.framework.dataspace.maintain.Reaper property) sequence_id (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) service_actions() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) set() (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) set_data_block() (decisionengine.framework.modules.Module.Module method) set_loglevel_value() (decisionengine.framework.engine.SourceWorkers.SourceWorker method) (decisionengine.framework.engine.tests.test_ChannelWorkers.TaskManager method) (decisionengine.framework.taskmanager.TaskManager.TaskManager method) set_state() (decisionengine.framework.dataspace.datablock.Metadata method) setup_logger() (decisionengine.framework.engine.ChannelWorkers.ChannelWorker method) (decisionengine.framework.engine.SourceWorkers.SourceWorker method) setup_queue_logging() (decisionengine.framework.modules.QueueLogger.QueueLogger method) (in module decisionengine.framework.modules.tests.test_QueueLogger) should_stop() (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) SHUTDOWN (decisionengine.framework.taskmanager.ProcessingState.State attribute) shutdown() (decisionengine.framework.modules.Publisher.Publisher method) SHUTTINGDOWN (decisionengine.framework.taskmanager.ProcessingState.State attribute) since (decisionengine.framework.taskmanager.PublisherStatus.PublisherState attribute) Singleton (class in decisionengine.framework.util.singleton) SingletonABC (class in decisionengine.framework.util.singleton) snapshot() (decisionengine.framework.taskmanager.PublisherStatus.PublisherStatusBoard method) sorted_rules() (decisionengine.framework.logicengine.FactLookup.FactLookup method) Source (class in decisionengine.framework.modules.Source) source_config() (in module decisionengine.framework.engine.tests.test_SourceWorkers) source_products() (in module decisionengine.framework.taskmanager.module_graph) source_worker_for() (in module decisionengine.framework.engine.tests.test_SourceWorkers) SourceNOP (class in decisionengine.framework.tests.SourceNOP) SourceProductCache (class in decisionengine.framework.taskmanager.SourceProductCache) SourceWithMissingProduces (class in decisionengine.framework.tests.SourceWithMissingProduces) SourceWithSampleConfigNOP (class in decisionengine.framework.tests.SourceWithSampleConfigNOP) SourceWorker (class in decisionengine.framework.engine.SourceWorkers) SourceWorkers (class in decisionengine.framework.engine.SourceWorkers)

SourceWorkers.Access (class in decisionengine.framework.engine.SourceWorkers) spec_if_main() (in module decisionengine.framework.modules.print_description) SQLALCHEMY_PG_WITH_SCHEMA() (in module decisionengine.framework.dataspace.datasources.tests.fixtures) (in module decisionengine.framework.dataspace.tests.fixtures) (in module decisionengine.framework.engine.tests.fixtures) (in module decisionengine.framework.tests.fixtures) SQLALCHEMY_TEMPFILE_SQLITE() (in module decisionengine.framework.dataspace.datasources.tests.fixtures) (in module decisionengine.framework.dataspace.tests.fixtures) (in module decisionengine.framework.engine.tests.fixtures) (in module decisionengine.framework.tests.fixtures) SQLAlchemyDS (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds) (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api) start() (decisionengine.framework.dataspace.maintain.Reaper method) (decisionengine.framework.modules.QueueLogger.QueueLogger method) start_channel() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) start_channels() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) start_webserver() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) State (class in decisionengine.framework.taskmanager.ProcessingState) state (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) state() (decisionengine.framework.taskmanager.PublisherStatus.PublisherStatus method) STEADY (decisionengine.framework.taskmanager.ProcessingState.State attribute) stop() (decisionengine.framework.dataspace.maintain.Reaper method) (decisionengine.framework.modules.QueueLogger.QueueLogger method) stop_channels() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) stop_queue_logger() (in module decisionengine.framework.modules.de_logger) stop_worker() (decisionengine.framework.engine.DecisionEngine.DecisionEngine method) stopped_channel_opts() (in module decisionengine.framework.tests.test_sample_config) StopState (class in decisionengine.framework.engine.DecisionEngine) store_taskmanager() (decisionengine.framework.dataspace.datablock.DataBlock method) (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) Summary (class in decisionengine.framework.util.metrics) supports_config() (in module decisionengine.framework.modules.describe) (in module decisionengine.framework.modules.Publisher) (in module decisionengine.framework.modules.Source) (in module decisionengine.framework.modules.Transform) SupportsConfig (class in decisionengine.framework.tests.SupportsConfigPublisher)

T

take_offline() (decisionengine.framework.engine.SourceWorkers.SourceWorker method) (decisionengine.framework.taskmanager.TaskManager.TaskManager method) task_dataproduct (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) task_header (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) task_metadata (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) Taskmanager (class in decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema) TaskManager (class in decisionengine.framework.engine.tests.test_ChannelWorkers) (class in decisionengine.framework.taskmanager.TaskManager) taskmanager (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Dataproduct attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) taskmanager_id (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Dataproduct attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Header attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Metadata attribute) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Taskmanager attribute) taskmanager_table (decisionengine.framework.dataspace.datasource.DataSource attribute) Terminated (decisionengine.framework.engine.DecisionEngine.StopState attribute) test() (decisionengine.framework.tests.ModuleProgramOptions.AcquireWithConfig method) (decisionengine.framework.tests.ModuleProgramOptions.AcquireWithSampleConfig method) (decisionengine.framework.tests.ModuleProgramOptions.ConfigTemplate method) (decisionengine.framework.tests.ModuleProgramOptions.Describe method) (decisionengine.framework.tests.ModuleProgramOptions.DescribeAlias method) (decisionengine.framework.tests.ModuleProgramOptions.Help method) test_acquire_for_sources() (in module decisionengine.framework.tests.test_module_program_options) test_allow_duplicate_keys_same_values() (in module decisionengine.framework.config.tests.test_de_std) test_allow_duplicate_source_proxy_keys() (in module decisionengine.framework.config.tests.test_de_std) test_by_nonsense_is_err() (in module decisionengine.framework.modules.tests.test_de_logger) test_by_size() (in module decisionengine.framework.modules.tests.test_de_logger) test_by_time() (in module decisionengine.framework.modules.tests.test_de_logger) test_can_import() (in module decisionengine.tests.test_framework_package) test_change_port() (in module decisionengine.framework.engine.tests.test_startup) test_channel_config_dir() (in module decisionengine.framework.config.tests.test_policies) test_channel_empty_config() (in module decisionengine.framework.config.tests.test_config) test_channel_empty_dictionary() (in module decisionengine.framework.config.tests.test_config) test_channel_invalid_modules_list() (in module decisionengine.framework.config.tests.test_config) test_channel_invalid_modules_no_keys() (in module decisionengine.framework.config.tests.test_config) test_channel_invalid_modules_string() (in module decisionengine.framework.config.tests.test_config) test_channel_loading() (in module decisionengine.framework.config.tests.test_config) test_channel_module_missing_all() (in module decisionengine.framework.config.tests.test_config) test_channel_module_missing_module() (in module decisionengine.framework.config.tests.test_config) test_channel_module_missing_parameters() (in module decisionengine.framework.config.tests.test_config) test_channel_names() (in module decisionengine.framework.config.tests.test_config) test_channel_no_config_files() (in module decisionengine.framework.config.tests.test_config) test_channel_no_modules() (in module decisionengine.framework.config.tests.test_config) test_check_metrics_env_no_webserver() (in module decisionengine.framework.engine.tests.test_startup) test_check_metrics_env_var_set() (in module decisionengine.framework.engine.tests.test_startup) test_check_metrics_env_var_unset() (in module decisionengine.framework.engine.tests.test_startup) test_client_can_get_de_server_reaper_status() (in module decisionengine.framework.tests.test_reaper) test_client_can_get_de_server_status() (in module decisionengine.framework.tests.test_sample_config) test_client_can_get_products_no_channels() (in module decisionengine.framework.tests.test_start_with_bad_channels) test_client_can_kill_one_channel() (in module decisionengine.framework.tests.test_sample_config) test_client_can_restart_all_channels() (in module decisionengine.framework.tests.test_sample_config) test_client_can_restart_one_channel() (in module decisionengine.framework.tests.test_sample_config) test_client_can_start_one_channel_added_after_startup() (in module decisionengine.framework.tests.test_empty_config) test_client_cannot_wait_on_bad_state() (in module decisionengine.framework.tests.test_client_errors) test_client_err_returned_as_rc() (in module decisionengine.framework.engine.tests.test_client_only) (in module decisionengine.framework.engine.tests.test_query_tool_only) test_client_err_returned_verbose_as_rc() (in module decisionengine.framework.engine.tests.test_client_only) (in module decisionengine.framework.engine.tests.test_query_tool_only) test_client_get_loglevel() (in module decisionengine.framework.tests.test_client_server) test_client_help() (in module decisionengine.framework.engine.tests.test_client_only) test_client_logger_level() (in module decisionengine.framework.tests.test_sample_config) test_client_non_real_channel() (in module decisionengine.framework.tests.test_sample_config) test_client_print_product() (in module decisionengine.framework.tests.test_client_server) test_client_set_loglevel() (in module decisionengine.framework.tests.test_client_server) test_client_status_msg_to_logger() (in module decisionengine.framework.tests.test_client_server) test_client_with_no_command_says_use_help() (in module decisionengine.framework.engine.tests.test_client_only) test_client_with_no_server() (in module decisionengine.framework.engine.tests.test_client_only) test_client_with_no_server_verbose() (in module decisionengine.framework.engine.tests.test_client_only) test_combine_one_level() (in module decisionengine.framework.config.tests.test_de_std) test_combine_one_level_skip_proxies() (in module decisionengine.framework.config.tests.test_de_std) test_combined_channels() (in module decisionengine.framework.tests.test_combined_channels) test_combined_channels_3g() (in module decisionengine.framework.tests.test_combined_channels) test_compound_fact_with_spaces() (in module decisionengine.framework.logicengine.tests.test_facts) test_compress() (in module decisionengine.framework.dataspace.tests.test_datablock_zlib) test_conditional_fact() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_config_templates() (in module decisionengine.framework.tests.test_module_program_options) test_configuration_with_fact_using_function() (in module decisionengine.framework.logicengine.tests.test_construction) test_configuration_with_numy_facts() (in module decisionengine.framework.logicengine.tests.test_construction) test_conflicting_source_configurations() (in module decisionengine.framework.tests.test_shared_sources) test_create_tables() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) test_DataBlock_constructor() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_duplicate() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_get_dataproducts() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_get_header() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_get_metadata() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_get_taskmanager() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_is_expired() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_is_expired_with_key() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_key_management() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_key_management_change_name() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_mark_expired() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_no_key_by_name() (in module decisionengine.framework.dataspace.tests.test_datablock) test_DataBlock_to_str() (in module decisionengine.framework.dataspace.tests.test_datablock) test_dataspace_config_finds_bad() (in module decisionengine.framework.dataspace.tests.test_dataspace) test_default_config() (in module decisionengine.framework.engine.tests.test_startup) test_default_construction() (in module decisionengine.framework.logicengine.tests.test_construction) test_defaults() (in module decisionengine.framework.tests.test_defaults) test_delete() (in module decisionengine.framework.dataspace.tests.test_dataspace) test_delete_data_older_than_arg() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) test_descriptions() (in module decisionengine.framework.tests.test_module_program_options) test_duplicate_datablock() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_duplicate_fact_names() (in module decisionengine.framework.logicengine.tests.test_duplicate_fact_names) test_dynamic_publisher() (in module decisionengine.framework.tests.test_dynamic_test_modules) test_dynamic_source() (in module decisionengine.framework.tests.test_dynamic_test_modules) test_dynamic_transform() (in module decisionengine.framework.tests.test_dynamic_test_modules) test_empty_config() (in module decisionengine.framework.config.tests.test_config) test_empty_source_structure() (in module decisionengine.framework.modules.tests.test_EmptySource) test_error_conditions() (in module decisionengine.framework.logicengine.tests.test_bool_function_name) test_error_on_acquire() (in module decisionengine.framework.tests.test_error_on_acquire) test_error_on_bad_names() (in module decisionengine.framework.logicengine.tests.test_simple_configuration) test_error_on_duplicate_keys() (in module decisionengine.framework.config.tests.test_de_std) test_exclusive_options() (in module decisionengine.framework.engine.tests.test_client_only) test_fact_using_numpy_array() (in module decisionengine.framework.logicengine.tests.test_facts) test_fact_using_numpy_function() (in module decisionengine.framework.logicengine.tests.test_facts) test_fact_with_fail_on_error() (in module decisionengine.framework.logicengine.tests.test_facts) test_fact_with_misspecified_attribute() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_fact_with_nested_names() (in module decisionengine.framework.logicengine.tests.test_facts) test_fail_bad_config() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_fail_missing_config() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_fail_missing_config_key() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_fail_on_error() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_fail_small_retain() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_fail_small_run_interval() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_fail_start_two_reapers() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_fail_wrong_config_key() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_false_fact_with_spaces() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_false_literal_fact() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_get_datablock() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace)

test_get_dataproduct() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_dataproduct_not_exist() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_dataproducts() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_dataproducts_not_exist() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_header() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_header_not_exist() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_last_generation_id() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_last_generation_id_not_exist() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_metadata() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_metadata_not_exist() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_taskmanager_exists() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_taskmanager_not_exists() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_taskmanagers() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_get_taskmanagers_not_exist() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_global_config_dir() (in module decisionengine.framework.config.tests.test_policies) test_global_config_file() (in module decisionengine.framework.config.tests.test_policies) test_has_config() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_has_methods_we_expect() (in module decisionengine.framework.dataspace.tests.test_datasource) test_Header_constructor() (in module decisionengine.framework.dataspace.tests.test_datablock) test_Header_is_valid() (in module decisionengine.framework.dataspace.tests.test_datablock) test_help() (in module decisionengine.framework.tests.test_module_program_options) test_index_error() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_insert() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_jpath() (in module decisionengine.framework.config.tests.test_de_std) test_just_stop_no_error() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_loop_of_start_stop_in_clumps() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_mark_expired() (in module decisionengine.framework.dataspace.tests.test_dataspace) test_Metadata_constructor() (in module decisionengine.framework.dataspace.tests.test_datablock) test_Metadata_set_state() (in module decisionengine.framework.dataspace.tests.test_datablock) test_minimal_jsonnet_right_extension() (in module decisionengine.framework.config.tests.test_config) test_minimal_jsonnet_wrong_extension() (in module decisionengine.framework.config.tests.test_config) test_missing_data_product_name_not_supported() (in module decisionengine.framework.modules.tests.test_EmptySource) test_misspecified_fact() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_module_alias() (in module decisionengine.framework.tests.test_module_program_options) test_module_structure() (in module decisionengine.framework.modules.tests.test_Module) test_multiple_consumes_declarations() (in module decisionengine.framework.modules.tests.test_module_decorators) test_multiple_produces_declarations() (in module decisionengine.framework.modules.tests.test_module_decorators) test_publisher_status() (in module decisionengine.framework.tests.test_publisher_status) test_publisher_status_board() (in module decisionengine.framework.tests.test_publisher_status_board) test_publisher_structure() (in module decisionengine.framework.modules.tests.test_Publisher) test_query_tool() (in module decisionengine.framework.tests.test_query_tool_server) test_query_tool_help() (in module decisionengine.framework.engine.tests.test_query_tool_only) test_query_tool_with_no_server() (in module decisionengine.framework.engine.tests.test_query_tool_only) test_query_tool_with_no_server_verbose() (in module decisionengine.framework.engine.tests.test_query_tool_only) test_reap_default_state() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_reaper_can_reap() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_reset_connections() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) test_rule_that_does_not_fire() (in module decisionengine.framework.logicengine.tests.test_cascaded_rules) (in module decisionengine.framework.logicengine.tests.test_pandas_fact) (in module decisionengine.framework.logicengine.tests.test_rule_with_negated_fact) (in module decisionengine.framework.logicengine.tests.test_simple_configuration) test_rule_that_fires() (in module decisionengine.framework.logicengine.tests.test_cascaded_rules) (in module decisionengine.framework.logicengine.tests.test_pandas_fact) (in module decisionengine.framework.logicengine.tests.test_rule_with_negated_fact) (in module decisionengine.framework.logicengine.tests.test_simple_configuration) test_same_source_types_separate_channels() (in module decisionengine.framework.tests.test_same_source_types) test_setup_queue_logging() (in module decisionengine.framework.modules.tests.test_QueueLogger) test_shared_source() (in module decisionengine.framework.tests.test_shared_sources) test_simple_fact() (in module decisionengine.framework.logicengine.tests.test_facts) test_source_fail_can_be_fixed() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_source_structure() (in module decisionengine.framework.modules.tests.test_Source) test_start_delay() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_start_queue_logger() (in module decisionengine.framework.modules.tests.test_QueueLogger) test_start_stop() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_start_stop_stop() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_state_can_be_active() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_state_sets_timer_and_uses_it() (in module decisionengine.framework.dataspace.tests.test_Reaper) test_status_during_startup() (in module decisionengine.framework.tests.test_status_during_startup) test_stop_queue_logger() (in module decisionengine.framework.modules.tests.test_QueueLogger) test_store_taskmanager() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_supports_config() (in module decisionengine.framework.modules.tests.test_module_decorators) test_syntax_error() (in module decisionengine.framework.logicengine.tests.test_facts) test_syntax_error_in_config_names_bad_file() (in module decisionengine.framework.config.tests.test_config) test_transform_structure() (in module decisionengine.framework.modules.tests.test_Transform) test_translate_all() (in module decisionengine.framework.modules.tests.test_translate_product_name) test_translate_illegal_characters() (in module decisionengine.framework.modules.tests.test_translate_product_name) test_translate_none() (in module decisionengine.framework.modules.tests.test_translate_product_name) test_translate_simple() (in module decisionengine.framework.modules.tests.test_translate_product_name) test_translate_with_underscores() (in module decisionengine.framework.modules.tests.test_translate_product_name) test_trivial_configuration() (in module decisionengine.framework.logicengine.tests.test_construction) test_true_fact() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_true_literal_fact() (in module decisionengine.framework.logicengine.tests.test_fail_on_error) test_update() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_update_bad() (in module decisionengine.framework.dataspace.datasources.tests.test_datasource_api) (in module decisionengine.framework.dataspace.tests.test_dataspace) test_valid_but_empty_config() (in module decisionengine.framework.config.tests.test_config) test_valid_dir() (in module decisionengine.framework.config.tests.test_policies) test_verify_bad_broker() (in module decisionengine.framework.engine.tests.test_verify_redis_server) test_verify_bad_redis_server() (in module decisionengine.framework.engine.tests.test_verify_redis_server) test_verify_bad_url() (in module decisionengine.framework.engine.tests.test_verify_redis_server) test_verify_redis_server() (in module decisionengine.framework.engine.tests.test_verify_redis_server) test_verify_redis_server_int() (in module decisionengine.framework.engine.tests.test_verify_redis_server) test_verify_redis_url() (in module decisionengine.framework.engine.tests.test_verify_redis_server) test_worker_logger_sized_rotation() (in module decisionengine.framework.engine.tests.test_ChannelWorkers) (in module decisionengine.framework.engine.tests.test_SourceWorkers) test_worker_logger_timed_rotation() (in module decisionengine.framework.engine.tests.test_ChannelWorkers) (in module decisionengine.framework.engine.tests.test_SourceWorkers) test_worker_logger_wrong_rotation_method() (in module decisionengine.framework.engine.tests.test_SourceWorkers) test_worker_name() (in module decisionengine.framework.engine.tests.test_ChannelWorkers) (in module decisionengine.framework.engine.tests.test_SourceWorkers) test_wrong_configuration() (in module decisionengine.framework.logicengine.tests.test_construction) test_wrong_product_names() (in module decisionengine.framework.modules.tests.test_module_decorators) test_wrong_product_types() (in module decisionengine.framework.modules.tests.test_module_decorators) test_zdumps() (in module decisionengine.framework.dataspace.tests.test_datablock_zlib) test_zloads() (in module decisionengine.framework.dataspace.tests.test_datablock_zlib) Transform (class in decisionengine.framework.modules.Transform) transform() (decisionengine.framework.modules.Transform.Transform method) (decisionengine.framework.tests.DynamicTransform.DynamicTransform method) (decisionengine.framework.tests.TransformNOP.TransformNOP method) (decisionengine.framework.tests.TransformWithMissingProducesConsumes.TransformWithMissingProducesConsumes method) TransformNOP (class in decisionengine.framework.tests.TransformNOP) TransformWithMissingProducesConsumes (class in decisionengine.framework.tests.TransformWithMissingProducesConsumes) translate() (in module decisionengine.framework.modules.translate_product_name) translate_all() (in module decisionengine.framework.modules.translate_product_name)

U

update() (decisionengine.framework.dataspace.datasource.DataSource method) (decisionengine.framework.dataspace.datasources.null.NullDataSource method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.datasource_api.SQLAlchemyDS method) (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.SQLAlchemyDS method) (decisionengine.framework.dataspace.dataspace.DataSpace method) (decisionengine.framework.engine.SourceWorkers.SourceWorkers method) (decisionengine.framework.taskmanager.PublisherStatus.PublisherStatusBoard method) (decisionengine.framework.taskmanager.SourceProductCache.SourceProductCache method)

V

valid_dir() (in module decisionengine.framework.config.policies) valid_states (decisionengine.framework.dataspace.datablock.Metadata attribute) validated_workflow() (in module decisionengine.framework.taskmanager.module_graph)

ValidConfig (class in decisionengine.framework.config.ValidConfig) value (decisionengine.framework.dataspace.datasources.sqlalchemy_ds.db_schema.Dataproduct attribute) verify_products() (in module decisionengine.framework.modules.Module)

W

wait_for_n_writes() (in module decisionengine.framework.tests.WriteToDisk) wait_until() (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method) wait_while() (decisionengine.framework.engine.ChannelWorkers.ChannelWorker method) (decisionengine.framework.taskmanager.ProcessingState.ProcessingState method)

Worker (class in decisionengine.framework.taskmanager.module_graph) WriteToDisk (class in decisionengine.framework.tests.WriteToDisk)

Z

zdumps() (in module decisionengine.framework.dataspace.datablock)

zloads() (in module decisionengine.framework.dataspace.datablock)