diff --git a/sdks/python/apache_beam/yaml/standard_providers.yaml b/sdks/python/apache_beam/yaml/standard_providers.yaml index 15d5fdc24914..242faaa9a77b 100644 --- a/sdks/python/apache_beam/yaml/standard_providers.yaml +++ b/sdks/python/apache_beam/yaml/standard_providers.yaml @@ -103,7 +103,6 @@ gradle_target: 'sdks:java:extensions:sql:expansion-service:shadowJar' - type: 'python' - config: - requires_gcp: true + config: {} transforms: Enrichment: 'apache_beam.yaml.yaml_enrichment.enrichment_transform' diff --git a/sdks/python/apache_beam/yaml/yaml_provider.py b/sdks/python/apache_beam/yaml/yaml_provider.py index 2d6ed2e5b956..c2cba936abce 100755 --- a/sdks/python/apache_beam/yaml/yaml_provider.py +++ b/sdks/python/apache_beam/yaml/yaml_provider.py @@ -231,17 +231,9 @@ def provider_from_spec(cls, spec): result.to_json = lambda: spec return result except Exception as exn: - if isinstance(exn, ModuleNotFoundError) and config.get('requires_gcp', - False): - print( - f"gcp dependencies not installed. Cannot use transforms: " - f"{', '.join(urns.keys())}. Please install using " - f"'pip install apache-beam[gcp]'.") - return InlineProvider({}) - else: - raise ValueError( - f'Unable to instantiate provider of type {type} ' - f'at line {SafeLineLoader.get_line(spec)}: {exn}') from exn + raise ValueError( + f'Unable to instantiate provider of type {type} ' + f'at line {SafeLineLoader.get_line(spec)}: {exn}') from exn else: raise NotImplementedError( f'Unknown provider type: {type} ' @@ -343,7 +335,7 @@ def cache_artifacts(self): @ExternalProvider.register_provider_type('python') -def python(urns, packages=(), requires_gcp=False): +def python(urns, packages=()): if packages: return ExternalPythonProvider(urns, packages) else: