Index

_

__all__ (in module pynenc_mongo) (in module pynenc_mongo.broker) (in module pynenc_mongo.client_data_store) (in module pynenc_mongo.orchestrator) (in module pynenc_mongo.state_backend) (in module pynenc_mongo.trigger) __getattr__() (pynenc_mongo.util.mongo_client.RetryableCollection method) _acquire_transition_lock() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _add_histories() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _atomic_status_transition() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _chunk_key() (in module pynenc_mongo.util.mongo_chunk_data) _compress() (in module pynenc_mongo.util.mongo_chunk_data) _decompress() (in module pynenc_mongo.util.mongo_chunk_data) _exceeds_bson_threshold() (in module pynenc_mongo.util.mongo_chunk_data) _get_active_runners() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _get_all_conditions() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) _get_exception() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _get_history() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _get_invocation() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _get_result() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _get_runner_context() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _get_runner_contexts() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _get_running_invocations_for_recovery() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _get_trigger() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) _instances (pynenc_mongo.util.mongo_client.PynencMongoClient attribute) _lock (pynenc_mongo.util.mongo_client.PynencMongoClient attribute)

_log_failure() (pynenc_mongo.util.mongo_client.RetryableCollection method) _log_retry() (pynenc_mongo.util.mongo_client.RetryableCollection method) _make_claim() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _MAX_INDEX_NS_BYTES (in module pynenc_mongo.util.mongo_client) _parse_claim_timestamp() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _parse_trigger_dto() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) _prefixed_name() (pynenc_mongo.util.mongo_collections.MongoCollections method) _purge() (pynenc_mongo.client_data_store.mongo_client_data_store.MongoClientDataStore method) (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) _reassemble_chunks() (in module pynenc_mongo.util.mongo_chunk_data) _register_condition() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) _register_new_invocations() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _register_source_task_condition() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) _release_transition_lock() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) _retrieve() (pynenc_mongo.client_data_store.mongo_client_data_store.MongoClientDataStore method) _retrieve_chunks() (in module pynenc_mongo.util.mongo_chunk_data) _set_exception() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _set_result() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _shorten_index_if_needed() (in module pynenc_mongo.util.mongo_client) _should_stop_retrying() (pynenc_mongo.util.mongo_client.RetryableCollection method) _split_into_chunks() (in module pynenc_mongo.util.mongo_chunk_data) _store() (pynenc_mongo.client_data_store.mongo_client_data_store.MongoClientDataStore method) _store_chunks() (in module pynenc_mongo.util.mongo_chunk_data) _store_runner_context() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _upsert_invocations() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) _wrap_with_retry() (pynenc_mongo.util.mongo_client.RetryableCollection method)

A

ALL_CHUNKED (pynenc_mongo.util.mongo_chunk_data.StorageKey attribute) any_non_final_invocations() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) APP_INFO_COLLECTION_SUFFIX (in module pynenc_mongo.state_backend.mongo_state_backend_collections) arg_cache() (pynenc_mongo.client_data_store.mongo_client_data_store.ArgCacheCollections method)

arg_cache_chunks() (pynenc_mongo.client_data_store.mongo_client_data_store.ArgCacheCollections method) ArgCacheCollections (class in pynenc_mongo.client_data_store.mongo_client_data_store) ARGS (pynenc_mongo.state_backend.mongo_state_backend.ChunkPrefix attribute) auto_purge() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method)

B

blocking_control (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator property) broker_message_queue() (pynenc_mongo.broker.mongo_broker.BrokerCollections method)

BrokerCollections (class in pynenc_mongo.broker.mongo_broker) build_chunk_key() (in module pynenc_mongo.util.mongo_chunk_data)

C

changed (pynenc_mongo.util.mongo_client.UpsertResult property) chunk_threshold (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) CHUNKED (pynenc_mongo.util.mongo_chunk_data.StorageKey attribute) ChunkPrefix (class in pynenc_mongo.state_backend.mongo_state_backend) claim_trigger_execution() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) claim_trigger_run() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) clean_task_trigger_definitions() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) clear_valid_conditions() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) CollectionSpec (class in pynenc_mongo.util.mongo_collections) compress() (in module pynenc_mongo.util.chunked_data) conf() (pynenc_mongo.broker.mongo_broker.MongoBroker method) (pynenc_mongo.client_data_store.mongo_client_data_store.MongoClientDataStore method) (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method)

ConfigBrokerMongo (class in pynenc_mongo.conf.config_broker) ConfigClientDataStoreMongo (class in pynenc_mongo.conf.config_client_data_store) ConfigMongo (class in pynenc_mongo.conf.config_mongo) ConfigOrchestratorMongo (class in pynenc_mongo.conf.config_orchestrator) ConfigStateBackendMongo (class in pynenc_mongo.conf.config_state_backend) ConfigTriggerMongo (class in pynenc_mongo.conf.config_trigger) count_invocations() (pynenc_mongo.broker.mongo_broker.MongoBroker method) (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method)

D

db (pynenc_mongo.util.mongo_client.PynencMongoClient property) decompress() (in module pynenc_mongo.util.chunked_data)

discover_app_infos() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend static method) DUPLICATE (pynenc_mongo.util.mongo_client.UpsertOutcome attribute)

E

exceeds_bson_threshold() (in module pynenc_mongo.util.chunked_data)

EXCEPTION (pynenc_mongo.state_backend.mongo_state_backend.ChunkPrefix attribute)

F

filter_by_status() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method)

G

get_all_workflow_runs() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_all_workflow_types() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_app_info() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_blocking_invocations() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoBlockingControl method) get_call_invocation_ids() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) get_child_invocations() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_collection() (pynenc_mongo.util.mongo_client.PynencMongoClient method) get_condition() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) get_conditions_sourced_from_task() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) get_conn_args() (in module pynenc_mongo.util.mongo_client) get_conn_key() (in module pynenc_mongo.util.mongo_client) get_existing_invocations() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) get_instance() (pynenc_mongo.util.mongo_client.PynencMongoClient class method)

get_invocation_ids_by_workflow() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_invocation_ids_paginated() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) get_invocation_retries() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) get_invocation_status_record() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) get_last_cron_execution() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) get_matching_runner_contexts() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_mongo_client() (in module pynenc_mongo.util.mongo_client) get_pending_invocations_for_recovery() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) get_task_invocation_ids() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) get_triggers_for_condition() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) get_valid_conditions() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) get_workflow_data() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_workflow_runs() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) get_workflow_sub_invocations() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method)

I

increment_invocation_retries() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) index_arguments_for_concurrency_control() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) indexes (pynenc_mongo.util.mongo_collections.CollectionSpec attribute) INLINE (pynenc_mongo.util.mongo_chunk_data.StorageKey attribute)

insert_or_ignore() (pynenc_mongo.util.mongo_client.RetryableCollection method) INSERTED (pynenc_mongo.util.mongo_client.UpsertOutcome attribute) instantiate_retriable_coll() (pynenc_mongo.util.mongo_collections.MongoCollections method) iter_history_in_timerange() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) iter_invocations_in_timerange() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method)

L

list_collection_names() (pynenc_mongo.util.mongo_client.PynencMongoClient method) lock_max_retries (pynenc_mongo.conf.config_orchestrator.ConfigOrchestratorMongo attribute) lock_retry_base_delay (pynenc_mongo.conf.config_orchestrator.ConfigOrchestratorMongo attribute) logger (in module pynenc_mongo.client_data_store.mongo_client_data_store) (in module pynenc_mongo.state_backend.mongo_state_backend) (in module pynenc_mongo.util.chunked_data) (in module pynenc_mongo.util.mongo_chunk_data) (in module pynenc_mongo.util.mongo_client)

M

matched_count (pynenc_mongo.util.mongo_client.UpsertResult attribute) max_retries (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) modified_count (pynenc_mongo.util.mongo_client.UpsertResult attribute) module pynenc_mongo pynenc_mongo.broker pynenc_mongo.broker.mongo_broker pynenc_mongo.builder pynenc_mongo.client_data_store pynenc_mongo.client_data_store.mongo_client_data_store pynenc_mongo.conf pynenc_mongo.conf.config_broker pynenc_mongo.conf.config_client_data_store pynenc_mongo.conf.config_mongo pynenc_mongo.conf.config_orchestrator pynenc_mongo.conf.config_state_backend pynenc_mongo.conf.config_trigger pynenc_mongo.orchestrator pynenc_mongo.orchestrator.mongo_orchestrator pynenc_mongo.orchestrator.mongo_orchestrator_collections pynenc_mongo.state_backend pynenc_mongo.state_backend.mongo_state_backend pynenc_mongo.state_backend.mongo_state_backend_collections pynenc_mongo.trigger pynenc_mongo.trigger.mongo_trigger pynenc_mongo.trigger.mongo_trigger_collections pynenc_mongo.util pynenc_mongo.util.chunked_data pynenc_mongo.util.mongo_chunk_data pynenc_mongo.util.mongo_client pynenc_mongo.util.mongo_collections

mongo() (in module pynenc_mongo.builder) mongo_auth_source (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) mongo_client_data_store() (in module pynenc_mongo.builder) mongo_db (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) MONGO_ERROR_INTERRUPTED (in module pynenc_mongo.util.mongo_client) MONGO_ERROR_INTERRUPTED_AT_SHUTDOWN (in module pynenc_mongo.util.mongo_client) MONGO_ERROR_NOT_PRIMARY_NO_SECONDARY_OK (in module pynenc_mongo.util.mongo_client) MONGO_ERROR_NOT_PRIMARY_OR_SECONDARY (in module pynenc_mongo.util.mongo_client) mongo_host (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) mongo_password (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) mongo_pool_max_connections (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) mongo_port (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) mongo_trigger() (in module pynenc_mongo.builder) mongo_url (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) mongo_username (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) MongoBlockingControl (class in pynenc_mongo.orchestrator.mongo_orchestrator) MongoBroker (class in pynenc_mongo.broker.mongo_broker) MongoBuilderPlugin (class in pynenc_mongo.builder) MongoClientDataStore (class in pynenc_mongo.client_data_store.mongo_client_data_store) MongoCollections (class in pynenc_mongo.util.mongo_collections) MongoOrchestrator (class in pynenc_mongo.orchestrator.mongo_orchestrator) MongoStateBackend (class in pynenc_mongo.state_backend.mongo_state_backend) MongoTrigger (class in pynenc_mongo.trigger.mongo_trigger)

N

name (pynenc_mongo.util.mongo_collections.CollectionSpec attribute)

O

orchestrator_blocking_edges() (pynenc_mongo.orchestrator.mongo_orchestrator_collections.OrchestratorCollections method) orchestrator_invocation_args() (pynenc_mongo.orchestrator.mongo_orchestrator_collections.OrchestratorCollections method) orchestrator_invocations() (pynenc_mongo.orchestrator.mongo_orchestrator_collections.OrchestratorCollections method)

orchestrator_runner_heartbeats() (pynenc_mongo.orchestrator.mongo_orchestrator_collections.OrchestratorCollections method) OrchestratorCollections (class in pynenc_mongo.orchestrator.mongo_orchestrator_collections) outcome (pynenc_mongo.util.mongo_client.UpsertResult attribute)

P

prepare_chunk_storage() (in module pynenc_mongo.util.mongo_chunk_data) purge() (pynenc_mongo.broker.mongo_broker.MongoBroker method) (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) purge_all() (pynenc_mongo.util.mongo_collections.MongoCollections method) pynenc_mongo module pynenc_mongo.broker module pynenc_mongo.broker.mongo_broker module pynenc_mongo.builder module pynenc_mongo.client_data_store module pynenc_mongo.client_data_store.mongo_client_data_store module pynenc_mongo.conf module pynenc_mongo.conf.config_broker module pynenc_mongo.conf.config_client_data_store module pynenc_mongo.conf.config_mongo module pynenc_mongo.conf.config_orchestrator module pynenc_mongo.conf.config_state_backend module pynenc_mongo.conf.config_trigger module

pynenc_mongo.orchestrator module pynenc_mongo.orchestrator.mongo_orchestrator module pynenc_mongo.orchestrator.mongo_orchestrator_collections module pynenc_mongo.state_backend module pynenc_mongo.state_backend.mongo_state_backend module pynenc_mongo.state_backend.mongo_state_backend_collections module pynenc_mongo.trigger module pynenc_mongo.trigger.mongo_trigger module pynenc_mongo.trigger.mongo_trigger_collections module pynenc_mongo.util module pynenc_mongo.util.chunked_data module pynenc_mongo.util.mongo_chunk_data module pynenc_mongo.util.mongo_client module pynenc_mongo.util.mongo_collections module PynencMongoClient (class in pynenc_mongo.util.mongo_client)

R

reassemble_chunks() (in module pynenc_mongo.util.chunked_data) record_atomic_service_execution() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) record_valid_condition() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) record_valid_conditions() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) register_builder_methods() (pynenc_mongo.builder.MongoBuilderPlugin static method) register_runner_heartbeats() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) register_trigger() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) release_waiters() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoBlockingControl method) RESULT (pynenc_mongo.state_backend.mongo_state_backend.ChunkPrefix attribute) retrieve_chunk_storage() (in module pynenc_mongo.util.mongo_chunk_data)

retrieve_invocation() (pynenc_mongo.broker.mongo_broker.MongoBroker method) retry_base_delay (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) retry_indefinitely (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) retry_max_delay (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) retry_max_time (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) RETRYABLE_EXCEPTIONS (in module pynenc_mongo.util.mongo_client) RETRYABLE_OPERATION_FAILURE_CODES (in module pynenc_mongo.util.mongo_client) RetryableCollection (class in pynenc_mongo.util.mongo_client) route_invocation() (pynenc_mongo.broker.mongo_broker.MongoBroker method) route_invocations() (pynenc_mongo.broker.mongo_broker.MongoBroker method)

S

sanitize_collection_prefix() (in module pynenc_mongo.util.mongo_collections) set_up_invocation_auto_purge() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoOrchestrator method) set_workflow_data() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) socket_connect_timeout (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) socket_timeout (pynenc_mongo.conf.config_mongo.ConfigMongo attribute) spec (pynenc_mongo.util.mongo_client.RetryableCollection property) split_into_chunks() (in module pynenc_mongo.util.chunked_data) stale_lock_threshold_seconds (pynenc_mongo.conf.config_orchestrator.ConfigOrchestratorMongo attribute) state_backend_app_info() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_chunks() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_exceptions() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_history() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method)

state_backend_invocations() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_results() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_runner_contexts() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_workflow_data() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_workflow_sub_invocations() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) state_backend_workflows() (pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections method) StateBackendCollections (class in pynenc_mongo.state_backend.mongo_state_backend_collections) StorageKey (class in pynenc_mongo.util.mongo_chunk_data) store_app_info() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) store_last_cron_execution() (pynenc_mongo.trigger.mongo_trigger.MongoTrigger method) store_workflow_run() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) store_workflow_sub_invocation() (pynenc_mongo.state_backend.mongo_state_backend.MongoStateBackend method) success (pynenc_mongo.util.mongo_client.UpsertResult property)

T

trg_condition_triggers() (pynenc_mongo.trigger.mongo_trigger_collections.TriggerCollections method) trg_conditions() (pynenc_mongo.trigger.mongo_trigger_collections.TriggerCollections method) trg_execution_claims() (pynenc_mongo.trigger.mongo_trigger_collections.TriggerCollections method) trg_source_task_conditions() (pynenc_mongo.trigger.mongo_trigger_collections.TriggerCollections method)

trg_trigger_run_claims() (pynenc_mongo.trigger.mongo_trigger_collections.TriggerCollections method) trg_triggers() (pynenc_mongo.trigger.mongo_trigger_collections.TriggerCollections method) trg_valid_conditions() (pynenc_mongo.trigger.mongo_trigger_collections.TriggerCollections method) TriggerCollections (class in pynenc_mongo.trigger.mongo_trigger_collections)

U

UPDATED (pynenc_mongo.util.mongo_client.UpsertOutcome attribute) upsert_document() (pynenc_mongo.util.mongo_client.RetryableCollection method)

upserted_id (pynenc_mongo.util.mongo_client.UpsertResult attribute) UpsertOutcome (class in pynenc_mongo.util.mongo_client) UpsertResult (class in pynenc_mongo.util.mongo_client)

V

validate_mongo_config() (in module pynenc_mongo.builder)

W

waiting_for_results() (pynenc_mongo.orchestrator.mongo_orchestrator.MongoBlockingControl method)