Maestro modules reference#
- maestro package
- Subpackages
- Submodules
- maestro.background_tasks module
- maestro.config module
AppConfigError
AppConfig
AppConfig.API_PORT
AppConfig.BUCKET
AppConfig.BUCKET_LOCK
AppConfig.ENV
AppConfig.GRACE_PERIOD
AppConfig.INSTANCE_ID
AppConfig.LOAD_MODELS_FROM
AppConfig.LOG_BACKUPS
AppConfig.LOG_DIR
AppConfig.LOG_LEVEL
AppConfig.LOG_MAX_BYTES
AppConfig.MAX_WORKERS
AppConfig.NATS_NKEYS_SEED
AppConfig.NATS_TLS_CA_CERT
AppConfig.NATS_URL
AppConfig.NEO4J_DATABASE
AppConfig.NEO4J_PASSWORD
AppConfig.NEO4J_SYNC_STREAM
AppConfig.NEO4J_SYNC_SUBJECT
AppConfig.NEO4J_URI
AppConfig.NEO4J_USER
AppConfig.STREAM
AppConfig.extract_prefixed_variables
AppConfig.nats_connect_options()
AppConfig.split_url_string
AppConfig.IS_RUNNING_IN_API
AppConfig.LOG_FILE
AppConfig.nats_ssl_context
- maestro.exceptions module
- maestro.models module
JobPriorityEnum
JobStatus
RelationshipEnum
MaestroBase
MaestroBase.additional_labels
MaestroBase.invalidated_at
MaestroBase.maestro_id
MaestroBase.class_labels()
MaestroBase.deserialize_collections
MaestroBase.get_nested()
MaestroBase.get_nested_iterables()
MaestroBase.get_subclass_matching_labels()
MaestroBase.model_dump_primitive()
MaestroBase.neo4j_datetime_to_native
MaestroBase.nested_fields()
MaestroBase.labels
MaestroBase.type
BaseArtefactModel
BaseArtefactModel.additional_labels
BaseArtefactModel.invalidated_at
BaseArtefactModel.maestro_id
BaseArtefactModel.class_labels()
BaseArtefactModel.class_serializer()
BaseArtefactModel.class_validator()
BaseArtefactModel.deserialize_collections
BaseArtefactModel.get_nested()
BaseArtefactModel.get_nested_iterables()
BaseArtefactModel.get_subclass_matching_labels()
BaseArtefactModel.model_dump_primitive()
BaseArtefactModel.neo4j_datetime_to_native
BaseArtefactModel.nested_fields()
BaseArtefactModel.subjects()
BaseArtefactModel.html
BaseArtefactModel.labels
BaseArtefactModel.properties
BaseArtefactModel.type
FileArtefactModel
FileArtefactModel.additional_labels
FileArtefactModel.invalidated_at
FileArtefactModel.maestro_id
FileArtefactModel.path
FileArtefactModel.class_labels()
FileArtefactModel.class_serializer()
FileArtefactModel.class_validator()
FileArtefactModel.deserialize_collections
FileArtefactModel.get_nested()
FileArtefactModel.get_nested_iterables()
FileArtefactModel.get_subclass_matching_labels()
FileArtefactModel.model_dump_primitive()
FileArtefactModel.neo4j_datetime_to_native
FileArtefactModel.nested_fields()
FileArtefactModel.path_is_absolute
FileArtefactModel.subjects()
FileArtefactModel.html
FileArtefactModel.labels
FileArtefactModel.properties
FileArtefactModel.size
FileArtefactModel.type
FileArtefactModel.updated_at
StdErrModel
StdErrModel.additional_labels
StdErrModel.invalidated_at
StdErrModel.maestro_id
StdErrModel.output
StdErrModel.class_labels()
StdErrModel.class_serializer()
StdErrModel.class_validator()
StdErrModel.deserialize_collections
StdErrModel.get_nested()
StdErrModel.get_nested_iterables()
StdErrModel.get_subclass_matching_labels()
StdErrModel.model_dump_primitive()
StdErrModel.neo4j_datetime_to_native
StdErrModel.nested_fields()
StdErrModel.subjects()
StdErrModel.html
StdErrModel.labels
StdErrModel.properties
StdErrModel.type
StdOutModel
StdOutModel.additional_labels
StdOutModel.invalidated_at
StdOutModel.maestro_id
StdOutModel.output
StdOutModel.class_labels()
StdOutModel.class_serializer()
StdOutModel.class_validator()
StdOutModel.deserialize_collections
StdOutModel.get_nested()
StdOutModel.get_nested_iterables()
StdOutModel.get_subclass_matching_labels()
StdOutModel.model_dump_primitive()
StdOutModel.neo4j_datetime_to_native
StdOutModel.nested_fields()
StdOutModel.subjects()
StdOutModel.html
StdOutModel.labels
StdOutModel.properties
StdOutModel.type
WorkflowStepModel
WorkflowStepModel.additional_labels
WorkflowStepModel.creation_date
WorkflowStepModel.invalidated_at
WorkflowStepModel.maestro_id
WorkflowStepModel.search_metadata
WorkflowStepModel.class_labels()
WorkflowStepModel.deserialize_collections
WorkflowStepModel.get_nested()
WorkflowStepModel.get_nested_iterables()
WorkflowStepModel.get_subclass_matching_labels()
WorkflowStepModel.model_dump_primitive()
WorkflowStepModel.neo4j_datetime_to_native
WorkflowStepModel.nested_fields()
WorkflowStepModel.labels
WorkflowStepModel.type
WorkflowStepModelWithStdOutAndStdErr
WorkflowStepModelWithStdOutAndStdErr.STDERR
WorkflowStepModelWithStdOutAndStdErr.STDOUT
WorkflowStepModelWithStdOutAndStdErr.additional_labels
WorkflowStepModelWithStdOutAndStdErr.creation_date
WorkflowStepModelWithStdOutAndStdErr.invalidated_at
WorkflowStepModelWithStdOutAndStdErr.maestro_id
WorkflowStepModelWithStdOutAndStdErr.search_metadata
WorkflowStepModelWithStdOutAndStdErr.class_labels()
WorkflowStepModelWithStdOutAndStdErr.deserialize_collections
WorkflowStepModelWithStdOutAndStdErr.get_nested()
WorkflowStepModelWithStdOutAndStdErr.get_nested_iterables()
WorkflowStepModelWithStdOutAndStdErr.get_subclass_matching_labels()
WorkflowStepModelWithStdOutAndStdErr.model_dump_primitive()
WorkflowStepModelWithStdOutAndStdErr.neo4j_datetime_to_native
WorkflowStepModelWithStdOutAndStdErr.nested_fields()
WorkflowStepModelWithStdOutAndStdErr.labels
WorkflowStepModelWithStdOutAndStdErr.type
WorkflowStepModelWithInput
WorkflowStepModelWithInput.INPUT
WorkflowStepModelWithInput.additional_labels
WorkflowStepModelWithInput.creation_date
WorkflowStepModelWithInput.invalidated_at
WorkflowStepModelWithInput.maestro_id
WorkflowStepModelWithInput.search_metadata
WorkflowStepModelWithInput.class_labels()
WorkflowStepModelWithInput.deserialize_collections
WorkflowStepModelWithInput.get_nested()
WorkflowStepModelWithInput.get_nested_iterables()
WorkflowStepModelWithInput.get_subclass_matching_labels()
WorkflowStepModelWithInput.model_dump_primitive()
WorkflowStepModelWithInput.neo4j_datetime_to_native
WorkflowStepModelWithInput.nested_fields()
WorkflowStepModelWithInput.labels
WorkflowStepModelWithInput.type
WorkflowStepModelWithOutput
WorkflowStepModelWithOutput.OUTPUT
WorkflowStepModelWithOutput.additional_labels
WorkflowStepModelWithOutput.creation_date
WorkflowStepModelWithOutput.invalidated_at
WorkflowStepModelWithOutput.maestro_id
WorkflowStepModelWithOutput.search_metadata
WorkflowStepModelWithOutput.class_labels()
WorkflowStepModelWithOutput.deserialize_collections
WorkflowStepModelWithOutput.get_nested()
WorkflowStepModelWithOutput.get_nested_iterables()
WorkflowStepModelWithOutput.get_subclass_matching_labels()
WorkflowStepModelWithOutput.model_dump_primitive()
WorkflowStepModelWithOutput.neo4j_datetime_to_native
WorkflowStepModelWithOutput.nested_fields()
WorkflowStepModelWithOutput.labels
WorkflowStepModelWithOutput.type
WorkflowStepModelWithArtefacts
WorkflowStepModelWithArtefacts.INPUT
WorkflowStepModelWithArtefacts.OUTPUT
WorkflowStepModelWithArtefacts.STDERR
WorkflowStepModelWithArtefacts.STDOUT
WorkflowStepModelWithArtefacts.additional_labels
WorkflowStepModelWithArtefacts.creation_date
WorkflowStepModelWithArtefacts.invalidated_at
WorkflowStepModelWithArtefacts.maestro_id
WorkflowStepModelWithArtefacts.search_metadata
WorkflowStepModelWithArtefacts.class_labels()
WorkflowStepModelWithArtefacts.deserialize_collections
WorkflowStepModelWithArtefacts.get_nested()
WorkflowStepModelWithArtefacts.get_nested_iterables()
WorkflowStepModelWithArtefacts.get_subclass_matching_labels()
WorkflowStepModelWithArtefacts.model_dump_primitive()
WorkflowStepModelWithArtefacts.neo4j_datetime_to_native
WorkflowStepModelWithArtefacts.nested_fields()
WorkflowStepModelWithArtefacts.labels
WorkflowStepModelWithArtefacts.type
Job
Job.additional_labels
Job.created_at
Job.display_name
Job.inputs
Job.instance_id
Job.invalidated_at
Job.maestro_id
Job.params
Job.pending_timeout
Job.priority
Job.revision
Job.running_timeout
Job.search_metadata
Job.status
Job.updated_at
Job.workflow_step
Job.class_labels()
Job.deserialize_collections
Job.get_nested()
Job.get_nested_iterables()
Job.get_subclass_matching_labels()
Job.model_dump_primitive()
Job.neo4j_datetime_to_native
Job.nested_fields()
Job.validate_input_properties
Job.validate_workflow_step
Job.validate_workflow_step_inputs
Job.hash
Job.labels
Job.name
Job.name_and_id
Job.type
Job.workflow_step_class
WorkflowModel
WorkflowModel.additional_labels
WorkflowModel.invalidated_at
WorkflowModel.jobs
WorkflowModel.maestro_id
WorkflowModel.search_metadata
WorkflowModel.workflow_name
WorkflowModel.class_labels()
WorkflowModel.deserialize_collections
WorkflowModel.get_nested()
WorkflowModel.get_nested_iterables()
WorkflowModel.get_subclass_matching_labels()
WorkflowModel.model_dump_primitive()
WorkflowModel.neo4j_datetime_to_native
WorkflowModel.nested_fields()
WorkflowModel.labels
WorkflowModel.type
- maestro.pipe module
- maestro.prefixing_stream module
- maestro.publishers module
- maestro.run module
- maestro.subreaper module
- maestro.subscribers module
- maestro.utils module
- maestro.worker module
- maestro.worker_queue module
- maestro.workflow_utils module