airflow/bin/cli.py
def dag_state(args):
    """
    Returns the state of a DagRun at the command line.
    >>> airflow dag_state tutorial 2015-01-01T00:00:00.000000
    running
    """
    dag = get_dag(args)
    dr = DagRun.find(dag.dag_id, execution_date=args.execution_date)
    print(dr[0].state if len(dr) > 0 else None)
def dag_state(args):
    """
    Returns the state of a DagRun at the command line.
    >>> airflow dag_state tutorial 2015-01-01T00:00:00.000000
    running
    """
    dag = get_dag(args)
    dr = DagRun.find(dag.dag_id, execution_date=args.execution_date)
    print(dr[0].state if len(dr) > 0 else None)
def dag_state ( args ) : dag = get_dag ( args ) dr = DagRun . find ( dag . dag_id , execution_date = args . execution_date ) print ( dr [ 0 ] . state if len ( dr ) > 0 else None )
Returns the state of a DagRun at the command line.
    >>> airflow dag_state tutorial 2015-01-01T00:00:00.000000
    running
Returns the state of a DagRun at the command line . >>> airflow dag_state tutorial 2015 - 01 - 01T00 : 00 : 00 . 000000 running