airflow/www/api/experimental/endpoints.py
def dag_paused(dag_id, paused):
    """(Un)pauses a dag"""

    DagModel = models.DagModel
    with create_session() as session:
        orm_dag = (
            session.query(DagModel)
                   .filter(DagModel.dag_id == dag_id).first()
        )
        if paused == 'true':
            orm_dag.is_paused = True
        else:
            orm_dag.is_paused = False
        session.merge(orm_dag)
        session.commit()

    return jsonify({'response': 'ok'})
def dag_paused(dag_id, paused):
    """(Un)pauses a dag"""

    DagModel = models.DagModel
    with create_session() as session:
        orm_dag = (
            session.query(DagModel)
                   .filter(DagModel.dag_id == dag_id).first()
        )
        if paused == 'true':
            orm_dag.is_paused = True
        else:
            orm_dag.is_paused = False
        session.merge(orm_dag)
        session.commit()

    return jsonify({'response': 'ok'})
def dag_paused ( dag_id , paused ) : DagModel = models . DagModel with create_session ( ) as session : orm_dag = ( session . query ( DagModel ) . filter ( DagModel . dag_id == dag_id ) . first ( ) ) if paused == 'true' : orm_dag . is_paused = True else : orm_dag . is_paused = False session . merge ( orm_dag ) session . commit ( ) return jsonify ( { 'response' : 'ok' } )
(Un)pauses a dag
( Un ) pauses a dag