def test_2_create_cluster_should_notice_existing_cluster_and_return_immediately(self):
        job_start = time.time()
        success = luigi.run(['--local-scheduler',
                             '--no-lock',
                             'CreateDataprocClusterTask',
                             '--gcloud-project-id=' + PROJECT_ID,
                             '--dataproc-cluster-name=' + CLUSTER_NAME])
        self.assertTrue(success)
        self.assertLess(time.time() - job_start, 3)
dataset/ETHPy150Open spotify/luigi/test/contrib/dataproc_test.py/DataprocTaskTest.test_2_create_cluster_should_notice_existing_cluster_and_return_immediately/original