pipelines.results package#
Submodules#
- pipelines.results.base module
GetPipelineMixinGetTaskMixinPipelineDigestItemPipelineExecutionPipelineResultPipelineResultsStoragePipelineResultsStorage.build_pipeline_execution()PipelineResultsStorage.cleanup()PipelineResultsStorage.get_pipeline_digest()PipelineResultsStorage.get_pipeline_execution()PipelineResultsStorage.get_pipeline_executions()PipelineResultsStorage.get_pipeline_result()PipelineResultsStorage.get_pipeline_results()PipelineResultsStorage.get_task_execution()PipelineResultsStorage.get_task_executions()PipelineResultsStorage.get_task_result()PipelineResultsStorage.get_task_results()
PipelineStorageObjectPipelineStorageObject.content_type_namePipelineStorageObject.get_completedPipelineStorageObject.get_input_dataPipelineStorageObject.get_pipeline_idPipelineStorageObject.get_run_idPipelineStorageObject.get_startedPipelineStorageObject.get_statusPipelineStorageObject.getter()PipelineStorageObject.method_prop_rePipelineStorageObject.report_status_change()PipelineStorageObject.savePipelineStorageObject.set_completedPipelineStorageObject.set_startedPipelineStorageObject.setter()
TaskExecutionTaskResultTaskResult.content_type_nameTaskResult.get_configTaskResult.get_duration()TaskResult.get_idTaskResult.get_pipeline_objectTaskResult.get_pipeline_taskTaskResult.get_serializable_pipeline_objectTaskResult.get_serializable_task_objectTaskResult.get_task_executionTaskResult.get_task_idTaskResult.get_task_object
- pipelines.results.helpers module
build_pipeline_execution()cleanup_task_results()get_pipeline_digest()get_pipeline_execution()get_pipeline_executions()get_pipeline_result()get_pipeline_results()get_pipeline_results_storage()get_task_execution()get_task_executions()get_task_result()get_task_results()reset_storage_object()
- pipelines.results.orm module
OrmPipelineResultsStorageOrmPipelineResultsStorage.build_pipeline_execution()OrmPipelineResultsStorage.cleanup()OrmPipelineResultsStorage.get_pipeline_digest()OrmPipelineResultsStorage.get_pipeline_execution()OrmPipelineResultsStorage.get_pipeline_executions()OrmPipelineResultsStorage.get_pipeline_result()OrmPipelineResultsStorage.get_pipeline_results()OrmPipelineResultsStorage.get_task_execution()OrmPipelineResultsStorage.get_task_executions()OrmPipelineResultsStorage.get_task_result()OrmPipelineResultsStorage.get_task_results()