diff --git a/sdks/python/apache_beam/runners/runner.py b/sdks/python/apache_beam/runners/runner.py index 8cbcf659963d..cf75a2b2804b 100644 --- a/sdks/python/apache_beam/runners/runner.py +++ b/sdks/python/apache_beam/runners/runner.py @@ -47,14 +47,6 @@ def create_runner(runner_name): RuntimeError: if an invalid runner name is used. """ - # TODO(BEAM-1185): Remove when all references to PipelineRunners are gone. - if 'PipelineRunner' in runner_name: - new_runner_name = runner_name.replace('PipelineRunner', 'Runner') - if new_runner_name in _ALL_KNOWN_RUNNERS: - logging.warning( - '%s is deprecated, use %s instead.', runner_name, new_runner_name) - runner_name = new_runner_name - if runner_name in _KNOWN_DIRECT_RUNNERS: runner_name = 'apache_beam.runners.direct.direct_runner.' + runner_name elif runner_name in _KNOWN_DATAFLOW_RUNNERS: diff --git a/sdks/python/apache_beam/runners/runner_test.py b/sdks/python/apache_beam/runners/runner_test.py index 88807b89cc45..ef2b994ebac3 100644 --- a/sdks/python/apache_beam/runners/runner_test.py +++ b/sdks/python/apache_beam/runners/runner_test.py @@ -66,12 +66,6 @@ def test_create_runner(self): isinstance(create_runner('TestDataflowRunner'), TestDataflowRunner)) self.assertRaises(ValueError, create_runner, 'xyz') - # TODO(BEAM-1185): Remove when all references to PipelineRunners are gone. - self.assertTrue( - isinstance(create_runner('DirectPipelineRunner'), DirectRunner)) - self.assertTrue( - isinstance(create_runner('DataflowPipelineRunner'), - DataflowRunner)) def test_remote_runner_translation(self): remote_runner = DataflowRunner()