def set_dags_paused_state(is_paused):
session = settings.Session()<EOL>dms = session.query(DagModel).filter(<EOL>DagModel.dag_id.in_(DAG_IDS))<EOL>for dm in dms:<EOL><INDENT>logging.info('<STR_LIT>'.format(dm, is_paused))<EOL>dm.is_paused = is_paused<EOL><DEDENT>session.commit()<EOL>
Toggle the pause state of the DAGs in the test.