Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/scheduler/sensor.py
| Show First 20 Lines • Show All 315 Lines • ▼ Show 20 Lines | ): | ||||
| except DagsterSubprocessError as e: | except DagsterSubprocessError as e: | ||||
| execution_plan_errors.extend(e.subprocess_error_infos) | execution_plan_errors.extend(e.subprocess_error_infos) | ||||
| except Exception as e: # pylint: disable=broad-except | except Exception as e: # pylint: disable=broad-except | ||||
| execution_plan_errors.append(serializable_error_info_from_exc_info(sys.exc_info())) | execution_plan_errors.append(serializable_error_info_from_exc_info(sys.exc_info())) | ||||
| pipeline_tags = external_pipeline.tags or {} | pipeline_tags = external_pipeline.tags or {} | ||||
| check_tags(pipeline_tags, "pipeline_tags") | check_tags(pipeline_tags, "pipeline_tags") | ||||
| tags = merge_dicts( | tags = merge_dicts( | ||||
| merge_dicts(pipeline_tags, run_request.tags), PipelineRun.tags_for_sensor(external_sensor) | merge_dicts(pipeline_tags, run_request.tags), PipelineRun.tags_for_sensor(external_sensor), | ||||
| ) | ) | ||||
| if run_request.run_key: | if run_request.run_key: | ||||
| tags[RUN_KEY_TAG] = run_request.run_key | tags[RUN_KEY_TAG] = run_request.run_key | ||||
| run = instance.create_run( | run = instance.create_run( | ||||
| pipeline_name=external_sensor.pipeline_name, | pipeline_name=external_sensor.pipeline_name, | ||||
| run_id=None, | run_id=None, | ||||
alangenfeld: does this show up anywhere useful? | |||||
| run_config=run_request.run_config, | run_config=run_request.run_config, | ||||
| mode=external_sensor.mode, | mode=external_sensor.mode, | ||||
| solids_to_execute=external_pipeline.solids_to_execute, | solids_to_execute=external_pipeline.solids_to_execute, | ||||
| step_keys_to_execute=None, | step_keys_to_execute=None, | ||||
| solid_selection=external_sensor.solid_selection, | solid_selection=external_sensor.solid_selection, | ||||
| status=( | status=( | ||||
| PipelineRunStatus.FAILURE | PipelineRunStatus.FAILURE | ||||
| if len(execution_plan_errors) > 0 | if len(execution_plan_errors) > 0 | ||||
| Show All 25 Lines | |||||
does this show up anywhere useful?