t oo created AIRFLOW-6356:
-----------------------------

             Summary: make cli only print output relevant to dag argument 
passed in rather than from any random dag in bag
                 Key: AIRFLOW-6356
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-6356
             Project: Apache Airflow
          Issue Type: Improvement
          Components: cli, DAG
    Affects Versions: 1.10.6
            Reporter: t oo


I have 5 different .py that each generate dynamic dags. One of the .py had a 
bug where it was printing exceptions for dagxyz instead of properly generating 
the dag.

 

now when I run airflow cli of 'get_state' dagabc I was not just getting the 
result for dagabc but also seeing the exception log printed related to  dagxyz! 
I am sure many other cli commands are affected since the log messages from 
OTHER dags in dagbag are not suppressed

 

[https://github.com/apache/airflow/blob/1.10.7/airflow/bin/cli.py#L589-L598]

The cli boasts only getting the state of a DagRun returned, not exception logs 
from other DAGs!

 
|Returns the state of a DagRun at the command line.|
| | >>> airflow dag_state tutorial 2015-01-01T00:00:00.000000|
| | running|



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to