diff --git a/sdks/python/apache_beam/runners/dataflow/template_runner_test.py b/sdks/python/apache_beam/runners/dataflow/template_runner_test.py index 09d9a7013a84..021056608f1f 100644 --- a/sdks/python/apache_beam/runners/dataflow/template_runner_test.py +++ b/sdks/python/apache_beam/runners/dataflow/template_runner_test.py @@ -75,27 +75,6 @@ def test_full_completion(self): ['job_name'], 'test-job') - def test_bad_path(self): - dummy_sdk_file = tempfile.NamedTemporaryFile() - remote_runner = DataflowRunner() - pipeline = Pipeline( - remote_runner, - options=PipelineOptions([ - '--dataflow_endpoint=ignored', - '--sdk_location=' + dummy_sdk_file.name, - '--job_name=test-job', - '--project=test-project', - '--staging_location=ignored', - '--temp_location=/dev/null', - '--template_location=/bad/path', - '--no_auth' - ])) - remote_runner.job = apiclient.Job( - pipeline._options, pipeline.to_runner_api()) - - with self.assertRaises(IOError): - pipeline.run().wait_until_finish() - if __name__ == '__main__': unittest.main()