`pynenc_mongo.state_backend.mongo_state_backend_collections`¶

Module Contents¶

Classes¶

StateBackendCollections

Collections specific to MongoStateBackend with prefix state_backend_.

Data¶

APP_INFO_COLLECTION_SUFFIX

API¶

pynenc_mongo.state_backend.mongo_state_backend_collections.APP_INFO_COLLECTION_SUFFIX¶: ‘state_backend_app_info’

class pynenc_mongo.state_backend.mongo_state_backend_collections.StateBackendCollections(conf: pynenc_mongo.conf.config_mongo.ConfigMongo, app_id: str)[source]¶

Bases: pynenc_mongo.util.mongo_collections.MongoCollections

Collections specific to MongoStateBackend with prefix state_backend_.

Initialization

state_backend_results() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_exceptions() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_invocations() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_history() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_workflows() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_app_info() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_workflow_data() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_workflow_sub_invocations() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_runner_contexts() → pynenc_mongo.util.mongo_client.RetryableCollection¶

state_backend_chunks() → pynenc_mongo.util.mongo_client.RetryableCollection¶

Collection for storing chunked data exceeding BSON limits.

Chunk documents structure: - chunk_key: “{invocation_id}:{data_type}:{item_key}” - seq: 0-based sequence number for chunk ordering - data: binary compressed chunk payload