HaloKo4 commented on issue #7735: [AIRFLOW-4549] Allow skipped tasks to satisfy 
wait_for_downstream
URL: https://github.com/apache/airflow/pull/7735#issuecomment-609638482
 
 
   I think there is an issue with the test
   ```
       def get_dag(subdir: Optional[str], dag_id: str) -> DAG:
           """Returns DAG of a given dag_id"""
           dagbag = DagBag(process_subdir(subdir))
           if dag_id not in dagbag.dags:
               raise AirflowException(
                   'dag_id could not be found: {}. Either the dag did not exist 
or it failed to '
   >               'parse.'.format(dag_id))
   E           airflow.exceptions.AirflowException: dag_id could not be found: 
test_depends_on_past. Either the dag did not exist or it failed to parse.
   ```

----------------------------------------------------------------
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

Reply via email to