ybendana commented on a change in pull request #4291: [AIRFLOW-1488] Add the
TriggeredDagRunSensor operator
URL: https://github.com/apache/airflow/pull/4291#discussion_r301829574
##########
File path: airflow/operators/dagrun_operator.py
##########
@@ -93,5 +93,6 @@ def execute(self, context):
conf=json.dumps(dro.payload),
execution_date=self.execution_date,
replace_microseconds=False)
+ self.run_id = dro.run_id
Review comment:
The dagrun operator needs to store the dagrun id so that it can return it
when it is called. For example, in the test_triggered_dagrun_sensor_dag.py,
this function triggers the dag and returns the id:
```
def triggerchild():
dr = trigger_dag(TEST_DAG_CHILD)
return [dr.run_id]
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
