Add 'pipeline_code_origin' to PipelineRun
a8e598f4852b
Actions

Description

Add 'pipeline_code_origin' to PipelineRun

Summary: A breaking change I would like to get into 0.12.0 - having this field set will allow us to launch queued runs without needing the gRPC server to be up at dequeue time (at least when you're not using the DefaultRunLauncher).

Test Plan: BK, Integration

Reviewers: johann, alangenfeld

Reviewed By: alangenfeld

Differential Revision: https://dagster.phacility.com/D8545

Details

Provenance

• dgibson

Authored on Jun 26 2021, 7:54 PM

Reviewer

alangenfeld

Differential Revision

D8545: Add 'pipeline_code_origin' to PipelineRun

Parents

R1:a566b62cf58a: Typehints for MayHaveInstanceWeakref

Branches

Unknown

Tags

Unknown

Event Timeline

• dgibson committed R1:a8e598f4852b: Add 'pipeline_code_origin' to PipelineRun (authored by • dgibson).Jul 3 2021, 2:48 AM

• dgibson added an edge: D8545: Add 'pipeline_code_origin' to PipelineRun.

Changes (17)

Path

Size

integration_tests/

test_suites/

celery-k8s-integration-test-suite/

test_queued_run_coordinator.py

daemon-test-suite/

test_queued.py

k8s-integration-test-suite/

test_executor.py

test_integration.py

python_modules/

dagster-graphql/

dagster_graphql/

implementation/

execution/

run_lifecycle.py

dagster/

cli/

pipeline.py

core/

execution/

instance/

storage/

daemon/

scheduler/

dagster_tests/

core_tests/

instance_tests/

test_instance.py

run_coordinator_tests/

test_default_run_coordinator.py

test_queued_run_coordinator.py

storage_tests/

test_pipeline_run.py

daemon_tests/

test_queued_run_coordinator_daemon.py

R1:a8e598f4852b

View Options

integration_tests/test_suites/celery-k8s-integration-test-suite/test_queued_run_coordinator.py

View Options

integration_tests/test_suites/daemon-test-suite/test_queued.py

View Options

integration_tests/test_suites/k8s-integration-test-suite/test_executor.py

View Options

integration_tests/test_suites/k8s-integration-test-suite/test_integration.py

View Options

python_modules/dagster-graphql/dagster_graphql/implementation/execution/run_lifecycle.py

View Options

python_modules/dagster/dagster/cli/pipeline.py

View Options

python_modules/dagster/dagster/core/execution/backfill.py

View Options

python_modules/dagster/dagster/core/instance/init.py

View Options

python_modules/dagster/dagster/core/storage/pipeline_run.py

View Options

python_modules/dagster/dagster/core/test_utils.py

View Options

python_modules/dagster/dagster/daemon/sensor.py

View Options

python_modules/dagster/dagster/scheduler/scheduler.py

View Options

python_modules/dagster/dagster_tests/core_tests/instance_tests/test_instance.py

View Options

python_modules/dagster/dagster_tests/core_tests/run_coordinator_tests/test_default_run_coordinator.py

View Options

python_modules/dagster/dagster_tests/core_tests/run_coordinator_tests/test_queued_run_coordinator.py

View Options

python_modules/dagster/dagster_tests/core_tests/storage_tests/test_pipeline_run.py

View Options

python_modules/dagster/dagster_tests/daemon_tests/test_queued_run_coordinator_daemon.py

Add 'pipeline_code_origin' to PipelineRuna8e598f4852bActions

Description

Details

Event Timeline

Changes (17)

R1:a8e598f4852b

integration_tests/test_suites/celery-k8s-integration-test-suite/test_queued_run_coordinator.py

integration_tests/test_suites/daemon-test-suite/test_queued.py

integration_tests/test_suites/k8s-integration-test-suite/test_executor.py

integration_tests/test_suites/k8s-integration-test-suite/test_integration.py

python_modules/dagster-graphql/dagster_graphql/implementation/execution/run_lifecycle.py

python_modules/dagster/dagster/cli/pipeline.py

python_modules/dagster/dagster/core/execution/backfill.py

python_modules/dagster/dagster/core/instance/__init__.py

python_modules/dagster/dagster/core/storage/pipeline_run.py

python_modules/dagster/dagster/core/test_utils.py

python_modules/dagster/dagster/daemon/sensor.py

python_modules/dagster/dagster/scheduler/scheduler.py

python_modules/dagster/dagster_tests/core_tests/instance_tests/test_instance.py

python_modules/dagster/dagster_tests/core_tests/run_coordinator_tests/test_default_run_coordinator.py

python_modules/dagster/dagster_tests/core_tests/run_coordinator_tests/test_queued_run_coordinator.py

python_modules/dagster/dagster_tests/core_tests/storage_tests/test_pipeline_run.py

python_modules/dagster/dagster_tests/daemon_tests/test_queued_run_coordinator_daemon.py

Add 'pipeline_code_origin' to PipelineRun
a8e598f4852b
Actions

python_modules/dagster/dagster/core/instance/init.py