pipelines package

Subpackages

• pipelines.management package
  • Subpackages
    • pipelines.management.commands package
      • Submodules
• pipelines.meta package
  • ClassWithAppConfigMeta
    • ClassWithAppConfigMeta.Meta
      • ClassWithAppConfigMeta.Meta.abstract
      • ClassWithAppConfigMeta.Meta.app_label
    • ClassWithAppConfigMeta.postprocess_meta()
  • ClassWithMeta
    • ClassWithMeta.Meta
      • ClassWithMeta.Meta.abstract
      • ClassWithMeta.Meta.name
      • ClassWithMeta.Meta.verbose_name
    • ClassWithMeta.get_meta()
    • ClassWithMeta.postprocess_meta()
    • ClassWithMeta.preprocess_meta()
• pipelines.reporters package
  • PipelineReporter
    • PipelineReporter.report()
    • PipelineReporter.report_context_object()
    • PipelineReporter.report_pipeline_execution()
    • PipelineReporter.report_pipeline_result()
    • PipelineReporter.report_task_execution()
    • PipelineReporter.report_task_result()
  • Submodules
    • pipelines.reporters.base module
      • MultiPipelineReporter
      • PipelineReporter
    • pipelines.reporters.logging module
      • LoggingReporter
    • pipelines.reporters.orm module
      • ORMReporter
• pipelines.results package
  • Submodules
    • pipelines.results.base module
      • GetPipelineMixin
      • GetTaskMixin
      • PipelineDigestItem
      • PipelineExecution
      • PipelineResult
      • PipelineResultsStorage
      • PipelineStorageObject
      • TaskExecution
      • TaskResult
    • 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
      • OrmPipelineResultsStorage
• pipelines.runners package
  • PipelineRunner
    • PipelineRunner.get_flat_task_list()
    • PipelineRunner.get_task_graph()
    • PipelineRunner.run()
    • PipelineRunner.start()
  • Subpackages
    • pipelines.runners.celery package
      • Submodules
  • Submodules
    • pipelines.runners.base module
      • PipelineRunner
    • pipelines.runners.eager module
      • Runner
• pipelines.tasks package
  • ModelTask
    • ModelTask.Meta
      • ModelTask.Meta.model
    • ModelTask.get_iterator()
    • ModelTask.get_queryset()
    • ModelTask.get_serializable_task_object()
  • Task
    • Task.ConfigType
    • Task.InputType
    • Task.clean_config()
    • Task.clean_input_data()
    • Task.get_id()
    • Task.get_iterator()
    • Task.get_serializable_task_object()
    • Task.pipeline_task
    • Task.run()
    • Task.start()
  • TaskConfig
    • TaskConfig.Config
      • TaskConfig.Config.extra
  • Submodules
    • pipelines.tasks.base module
      • ConfigValidationError
      • InputValidationError
      • ModelTask
      • Task
      • TaskConfig
      • TaskError
    • pipelines.tasks.registry module
      • TaskRegistry
• pipelines.templatetags package
  • Submodules
    • pipelines.templatetags.pipelines module
      • duration()
      • lookup()
      • status_class()
      • status_text()

Submodules

• pipelines.admin module
  • PipelineLogAdmin
    • PipelineLogAdmin.list_display
    • PipelineLogAdmin.list_filter
    • PipelineLogAdmin.media
  • PipelineResultAdmin
    • PipelineResultAdmin.list_display
    • PipelineResultAdmin.media
  • TaskResultAdmin
    • TaskResultAdmin.list_display
    • TaskResultAdmin.media
• pipelines.apps module
  • PipelinesConfig
    • PipelinesConfig.default_auto_field
    • PipelinesConfig.name
    • PipelinesConfig.ready()
    • PipelinesConfig.verbose_name
• pipelines.baker_recipes module
• pipelines.base module
  • ModelPipeline
    • ModelPipeline.Meta
      • ModelPipeline.Meta.abstract
      • ModelPipeline.Meta.model
    • ModelPipeline.get_iterator()
    • ModelPipeline.get_queryset()
    • ModelPipeline.get_serializable_pipeline_object()
    • ModelPipeline.tasks
  • Pipeline
    • Pipeline.clean_parents()
    • Pipeline.clean_tasks()
    • Pipeline.get_id()
    • Pipeline.get_iterator()
    • Pipeline.get_serializable_pipeline_object()
    • Pipeline.handle_config_error()
    • Pipeline.ordering
    • Pipeline.postprocess_meta()
    • Pipeline.start()
    • Pipeline.tasks
• pipelines.config module
  • Config
    • Config.PIPELINES_CLEAR_LOG_DAYS
    • Config.PIPELINES_DEFAULT_PIPELINE_REPORTER
    • Config.PIPELINES_DEFAULT_PIPELINE_RUNNER
    • Config.PIPELINES_DEFAULT_PIPELINE_STORAGE
  • object_from_config()
• pipelines.forms module
  • LogFilterForm
    • LogFilterForm.base_fields
    • LogFilterForm.declared_fields
    • LogFilterForm.id
    • LogFilterForm.media
    • LogFilterForm.qs
    • LogFilterForm.type
  • PipelineStartForm
    • PipelineStartForm.base_fields
    • PipelineStartForm.declared_fields
    • PipelineStartForm.media
• pipelines.log module
• pipelines.models module
  • OrmPipelineExecution
    • OrmPipelineExecution.DoesNotExist
    • OrmPipelineExecution.MultipleObjectsReturned
    • OrmPipelineExecution.completed
    • OrmPipelineExecution.get_pipeline()
    • OrmPipelineExecution.get_pipeline_results()
    • OrmPipelineExecution.get_status()
    • OrmPipelineExecution.get_status_display()
    • OrmPipelineExecution.id
    • OrmPipelineExecution.input_data
    • OrmPipelineExecution.objects
    • OrmPipelineExecution.pipeline_id
    • OrmPipelineExecution.results
    • OrmPipelineExecution.run_id
    • OrmPipelineExecution.started
    • OrmPipelineExecution.status
  • OrmPipelineExecutionQuerySet
    • OrmPipelineExecutionQuerySet.with_extra_stats()
  • OrmPipelineResult
    • OrmPipelineResult.DoesNotExist
    • OrmPipelineResult.MultipleObjectsReturned
    • OrmPipelineResult.completed
    • OrmPipelineResult.execution
    • OrmPipelineResult.execution_id
    • OrmPipelineResult.failed
    • OrmPipelineResult.get_pipeline()
    • OrmPipelineResult.get_pipeline_execution()
    • OrmPipelineResult.get_status()
    • OrmPipelineResult.get_status_display()
    • OrmPipelineResult.get_task_executions()
    • OrmPipelineResult.id
    • OrmPipelineResult.input_data
    • OrmPipelineResult.objects
    • OrmPipelineResult.pipeline_id
    • OrmPipelineResult.pipeline_object
    • OrmPipelineResult.reporter
    • OrmPipelineResult.run_id
    • OrmPipelineResult.runner
    • OrmPipelineResult.serializable_pipeline_object
    • OrmPipelineResult.started
    • OrmPipelineResult.status
    • OrmPipelineResult.task_executions
  • OrmPipelineResultQuerySet
    • OrmPipelineResultQuerySet.for_run_id()
    • OrmPipelineResultQuerySet.with_extra_stats()
  • OrmTaskExecution
    • OrmTaskExecution.DoesNotExist
    • OrmTaskExecution.MultipleObjectsReturned
    • OrmTaskExecution.completed
    • OrmTaskExecution.config
    • OrmTaskExecution.get_status()
    • OrmTaskExecution.get_status_display()
    • OrmTaskExecution.get_task()
    • OrmTaskExecution.get_task_results()
    • OrmTaskExecution.id
    • OrmTaskExecution.input_data
    • OrmTaskExecution.objects
    • OrmTaskExecution.pipeline_id
    • OrmTaskExecution.pipeline_object
    • OrmTaskExecution.pipeline_result
    • OrmTaskExecution.pipeline_result_id
    • OrmTaskExecution.pipeline_task
    • OrmTaskExecution.results
    • OrmTaskExecution.run_id
    • OrmTaskExecution.serializable_pipeline_object
    • OrmTaskExecution.started
    • OrmTaskExecution.status
    • OrmTaskExecution.task_id
  • OrmTaskResult
    • OrmTaskResult.DoesNotExist
    • OrmTaskResult.MultipleObjectsReturned
    • OrmTaskResult.completed
    • OrmTaskResult.config
    • OrmTaskResult.duration
    • OrmTaskResult.execution
    • OrmTaskResult.execution_id
    • OrmTaskResult.get_status()
    • OrmTaskResult.get_status_display()
    • OrmTaskResult.get_task()
    • OrmTaskResult.get_task_execution()
    • OrmTaskResult.id
    • OrmTaskResult.input_data
    • OrmTaskResult.objects
    • OrmTaskResult.pipeline_id
    • OrmTaskResult.pipeline_object
    • OrmTaskResult.pipeline_task
    • OrmTaskResult.run_id
    • OrmTaskResult.serializable_pipeline_object
    • OrmTaskResult.serializable_task_object
    • OrmTaskResult.started
    • OrmTaskResult.status
    • OrmTaskResult.task_id
    • OrmTaskResult.task_object
  • OrmTaskResultQuerySet
    • OrmTaskResultQuerySet.for_run_id()
    • OrmTaskResultQuerySet.not_completed()
    • OrmTaskResultQuerySet.with_duration()
  • PipelineLog
    • PipelineLog.DoesNotExist
    • PipelineLog.MultipleObjectsReturned
    • PipelineLog.context_id
    • PipelineLog.context_type
    • PipelineLog.created
    • PipelineLog.get_context_type_display()
    • PipelineLog.get_next_by_created()
    • PipelineLog.get_next_by_modified()
    • PipelineLog.get_previous_by_created()
    • PipelineLog.get_previous_by_modified()
    • PipelineLog.get_status_display()
    • PipelineLog.id
    • PipelineLog.log_message
    • PipelineLog.message
    • PipelineLog.modified
    • PipelineLog.objects
    • PipelineLog.pipeline_id
    • PipelineLog.run_id
    • PipelineLog.status
  • TaskExecutionQuerySet
    • TaskExecutionQuerySet.for_run_id()
    • TaskExecutionQuerySet.not_completed()
    • TaskExecutionQuerySet.with_duration()
• pipelines.registry module
  • PipeLineRegistry
  • Registrable
    • Registrable.get_id()
    • Registrable.get_urls()
  • Registry
    • Registry.autodiscover()
    • Registry.get_all_items()
    • Registry.get_by_app_label()
    • Registry.get_by_classname()
    • Registry.get_by_id()
    • Registry.get_urls()
    • Registry.items
    • Registry.register()
    • Registry.remove()
    • Registry.reset()
    • Registry.urls
• pipelines.status module
  • PipelineTaskStatus
    • PipelineTaskStatus.CANCELLED
    • PipelineTaskStatus.CONFIG_ERROR
    • PipelineTaskStatus.DONE
    • PipelineTaskStatus.PENDING
    • PipelineTaskStatus.RUNNING
    • PipelineTaskStatus.RUNTIME_ERROR
    • PipelineTaskStatus.VALIDATION_ERROR
    • PipelineTaskStatus.choices()
    • PipelineTaskStatus.failed_statuses()
    • PipelineTaskStatus.final_statuses()
    • PipelineTaskStatus.has_advanced()
    • PipelineTaskStatus.non_final_statuses()
    • PipelineTaskStatus.success_statuses()
• pipelines.urls module
• pipelines.utils module
  • get_django_object()
  • get_object()
• pipelines.views module
  • IsStaffRequiredMixin
    • IsStaffRequiredMixin.dispatch()
  • LogFilterView
    • LogFilterView.get_context_data()
    • LogFilterView.log_url
    • LogFilterView.template_name
  • LogListView
    • LogListView.all_tasks_completed()
    • LogListView.get()
    • LogListView.get_context_data()
    • LogListView.get_logs()
    • LogListView.pipeline_execution
    • LogListView.template_name
  • PipelineExecutionListView
    • PipelineExecutionListView.get_context_data()
    • PipelineExecutionListView.get_queryset()
    • PipelineExecutionListView.paginate_by
    • PipelineExecutionListView.template_name
  • PipelineListView
    • PipelineListView.get_context_data()
    • PipelineListView.template_name
  • PipelineResultView
    • PipelineResultView.template_name
  • PipelineStartView
    • PipelineStartView.form_class
    • PipelineStartView.form_valid()
    • PipelineStartView.get_context_data()
    • PipelineStartView.get_form_kwargs()
    • PipelineStartView.get_success_url()
    • PipelineStartView.template_name
  • TaskResultListView
    • TaskResultListView.all_tasks_completed()
    • TaskResultListView.get()
    • TaskResultListView.get_queryset()
    • TaskResultListView.pipeline_execution
    • TaskResultListView.template_name
  • TaskResultReRunView
    • TaskResultReRunView.get()
    • TaskResultReRunView.get_object()
    • TaskResultReRunView.get_redirect_url()