Description

legacy_examples/

dagster_examples/

bay_bikes/

parse_dataproc_configs.py

dagster_examples_tests/

event_pipeline_demo_tests/

test_airflowized.py

python_modules/

automation/

parse_spark_configs.py

release/

pypirc.py

dagit/

dagit_tests/

test_app.py

dagster-graphql/

dagster_graphql/

dauphin_registry.py

implementation/

pipeline_run_storage.py

schema/

schedules/

schedule_definition.py

schedule_state.py

solids.py

dagster-test/

dagster_test/

toys/

dagster/

config/

core/

definitions/

decorators/

intermediate_storage.py

execution/

context/

plan/

executor/

child_process_executor.py

host_representation/

grpc_server_state_subscriber.py

storage/

compute_log_manager.py

local_compute_log_manager.py

temp_file_manager.py

type_storage.py

system_config/

objects.py

types/

builtin_config_schemas.py

daemon/

grpc/

utils/

dagster_tests/

core_tests/

definitions_tests/

test_definition_errors.py

test_pipeline.py

execution_tests/

test_custom_reconstructable.py

runtime_types_tests/

test_dagster_type_decorator.py

test_types.py

test_composites.py

general_tests/

check_tests/

test_check.py

py3_tests/

test_inference.py

libraries/

dagster-airflow/

dagster_airflow/

operators/

docker_operator.py

dagster_airflow_tests/

test_factory/

test_pipeline_run_creation.py

dagster-aws/

dagster_aws/

s3/

s3_fake_resource.py

utils.py

utils/

mrjob/

retry.py

dagster-azure/

dagster_azure/

adls2/

fake_adls2_resource.py

blob/

fake_blob_client.py

dagster-celery/

dagster_celery/

config.py

dagster-dask/

dagster_dask/

dagster-gcp/

dagster_gcp/

dataproc/

dagster-pagerduty/

dagster_pagerduty/

dagster-pandas/

dagster_pandas/

constraints.py

dagster-postgres/

dagster_postgres/

event_log/

event_log.py

dagster-prometheus/

dagster_prometheus/

dagster-pyspark/

dagster_pyspark/

dagster-ssh/

dagster_ssh/

dagstermill/

examples/

repository.py

manager.py

dagstermill_tests/

test_manager.py

R1:18867720e7c3

.buildkite/step_builder.py

examples/docs_snippets/docs_snippets/intro_tutorial/advanced/pipelines/modes.py

examples/docs_snippets/docs_snippets/intro_tutorial/advanced/pipelines/presets.py

examples/docs_snippets/docs_snippets/intro_tutorial/advanced/pipelines/required_resources.py

examples/docs_snippets/docs_snippets/intro_tutorial/advanced/pipelines/resources.py

examples/legacy_examples/dagster_examples/bay_bikes/resources.py

examples/legacy_examples/dagster_examples_tests/event_pipeline_demo_tests/test_airflowized.py

python_modules/automation/automation/parse_dataproc_configs.py

python_modules/automation/automation/parse_spark_configs.py

python_modules/automation/automation/release/pypirc.py

python_modules/dagit/dagit_tests/test_app.py

python_modules/dagster-graphql/dagster_graphql/dauphin_registry.py

python_modules/dagster-graphql/dagster_graphql/implementation/pipeline_run_storage.py

python_modules/dagster-graphql/dagster_graphql/schema/assets.py

python_modules/dagster-graphql/dagster_graphql/schema/config_types.py

python_modules/dagster-graphql/dagster_graphql/schema/dagster_types.py

python_modules/dagster-graphql/dagster_graphql/schema/errors.py

python_modules/dagster-graphql/dagster_graphql/schema/execution.py

python_modules/dagster-graphql/dagster_graphql/schema/external.py

python_modules/dagster-graphql/dagster_graphql/schema/paging.py

python_modules/dagster-graphql/dagster_graphql/schema/partition_sets.py

python_modules/dagster-graphql/dagster_graphql/schema/pipelines.py

python_modules/dagster-graphql/dagster_graphql/schema/roots.py

python_modules/dagster-graphql/dagster_graphql/schema/runs.py

python_modules/dagster-graphql/dagster_graphql/schema/schedules/init.py

python_modules/dagster-graphql/dagster_graphql/schema/schedules/schedule_definition.py

python_modules/dagster-graphql/dagster_graphql/schema/schedules/schedule_state.py

python_modules/dagster-graphql/dagster_graphql/schema/solids.py

python_modules/dagster-test/dagster_test/toys/error_monster.py

python_modules/dagster/dagster/builtins.py

python_modules/dagster/dagster/config/config_schema.py

python_modules/dagster/dagster/config/config_type.py

python_modules/dagster/dagster/config/field.py

python_modules/dagster/dagster/config/field_utils.py

python_modules/dagster/dagster/config/run_config.py

python_modules/dagster/dagster/config/stack.py

python_modules/dagster/dagster/config/traversal_context.py

python_modules/dagster/dagster/core/decorator_utils.py

python_modules/dagster/dagster/core/definitions/composition.py

python_modules/dagster/dagster/core/definitions/decorators/composite_solid.py

python_modules/dagster/dagster/core/definitions/decorators/hook.py

python_modules/dagster/dagster/core/definitions/decorators/lambda_solid.py

python_modules/dagster/dagster/core/definitions/decorators/pipeline.py

python_modules/dagster/dagster/core/definitions/decorators/repository.py

python_modules/dagster/dagster/core/definitions/decorators/solid.py

python_modules/dagster/dagster/core/definitions/dependency.py

python_modules/dagster/dagster/core/definitions/executor.py

python_modules/dagster/dagster/core/definitions/input.py

python_modules/dagster/dagster/core/definitions/intermediate_storage.py

python_modules/dagster/dagster/core/definitions/job.py

python_modules/dagster/dagster/core/definitions/output.py

python_modules/dagster/dagster/core/definitions/reconstructable.py

python_modules/dagster/dagster/core/definitions/repository.py

python_modules/dagster/dagster/core/definitions/resource.py

python_modules/dagster/dagster/core/definitions/system_storage.py

python_modules/dagster/dagster/core/execution/api.py

python_modules/dagster/dagster/core/execution/context/step.py

python_modules/dagster/dagster/core/execution/context/system.py

python_modules/dagster/dagster/core/execution/plan/active.py

python_modules/dagster/dagster/core/execution/plan/plan.py

python_modules/dagster/dagster/core/execution/resources_init.py

python_modules/dagster/dagster/core/execution/results.py

python_modules/dagster/dagster/core/executor/child_process_executor.py

python_modules/dagster/dagster/core/host_representation/grpc_server_state_subscriber.py

python_modules/dagster/dagster/core/storage/compute_log_manager.py

python_modules/dagster/dagster/core/storage/local_compute_log_manager.py

python_modules/dagster/dagster/core/storage/temp_file_manager.py

python_modules/dagster/dagster/core/storage/type_storage.py

python_modules/dagster/dagster/core/system_config/objects.py

python_modules/dagster/dagster/core/types/builtin_config_schemas.py

python_modules/dagster/dagster/core/types/config_schema.py

python_modules/dagster/dagster/core/types/dagster_type.py

python_modules/dagster/dagster/core/types/python_dict.py

python_modules/dagster/dagster/daemon/controller.py

python_modules/dagster/dagster/daemon/daemon.py

python_modules/dagster/dagster/grpc/client.py

python_modules/dagster/dagster/grpc/server.py

python_modules/dagster/dagster/utils/init.py

python_modules/dagster/dagster/utils/indenting_printer.py

python_modules/dagster/dagster/utils/timing.py

python_modules/dagster/dagster_tests/core_tests/definitions_tests/test_definition_errors.py

python_modules/dagster/dagster_tests/core_tests/definitions_tests/test_pipeline.py

python_modules/dagster/dagster_tests/core_tests/execution_tests/test_custom_reconstructable.py

python_modules/dagster/dagster_tests/core_tests/runtime_types_tests/test_dagster_type_decorator.py

python_modules/dagster/dagster_tests/core_tests/runtime_types_tests/test_types.py

python_modules/dagster/dagster_tests/core_tests/test_composites.py

python_modules/dagster/dagster_tests/general_tests/check_tests/test_check.py

python_modules/dagster/dagster_tests/general_tests/py3_tests/test_inference.py

python_modules/libraries/dagster-airflow/dagster_airflow/operators/docker_operator.py

python_modules/libraries/dagster-airflow/dagster_airflow_tests/test_factory/test_pipeline_run_creation.py

python_modules/libraries/dagster-aws/dagster_aws/s3/s3_fake_resource.py

python_modules/libraries/dagster-aws/dagster_aws/s3/utils.py

python_modules/libraries/dagster-aws/dagster_aws/utils/mrjob/retry.py

python_modules/libraries/dagster-azure/dagster_azure/adls2/fake_adls2_resource.py

python_modules/libraries/dagster-azure/dagster_azure/adls2/resources.py

python_modules/libraries/dagster-azure/dagster_azure/blob/fake_blob_client.py

python_modules/libraries/dagster-celery/dagster_celery/config.py

python_modules/libraries/dagster-dask/dagster_dask/resources.py

python_modules/libraries/dagster-gcp/dagster_gcp/dataproc/resources.py

python_modules/libraries/dagster-pagerduty/dagster_pagerduty/resources.py

python_modules/libraries/dagster-pandas/dagster_pandas/constraints.py

python_modules/libraries/dagster-postgres/dagster_postgres/event_log/event_log.py

python_modules/libraries/dagster-prometheus/dagster_prometheus/resources.py

python_modules/libraries/dagster-pyspark/dagster_pyspark/resources.py

python_modules/libraries/dagster-ssh/dagster_ssh/resources.py

python_modules/libraries/dagstermill/dagstermill/examples/repository.py

python_modules/libraries/dagstermill/dagstermill/manager.py

python_modules/libraries/dagstermill/dagstermill_tests/test_manager.py