'Test paused DAG should fail dependency'

def test_concurrency_reached(self):

    dag = Mock(is_paused=True)
    task = Mock(dag=dag)
    ti = TaskInstance(task=task, execution_date=None)
    self.assertFalse(DagUnpausedDep().is_met(ti=ti))
