This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new a7bf59436a6 Removing Depreciation warning when using pipeline.options
(#28774)
a7bf59436a6 is described below
commit a7bf59436a664dca932c5001b750514dab2fa296
Author: aku019 <[email protected]>
AuthorDate: Tue Oct 3 03:26:34 2023 +0530
Removing Depreciation warning when using pipeline.options (#28774)
Co-authored-by: [email protected] <India@wc2019>
---
sdks/python/apache_beam/pipeline.py | 4 ----
sdks/python/apache_beam/runners/interactive/interactive_beam.py | 6 ------
.../apache_beam/runners/interactive/interactive_environment.py | 6 ------
sdks/python/apache_beam/runners/interactive/recording_manager.py | 5 -----
4 files changed, 21 deletions(-)
diff --git a/sdks/python/apache_beam/pipeline.py
b/sdks/python/apache_beam/pipeline.py
index 18b422ed27d..042b483d50f 100644
--- a/sdks/python/apache_beam/pipeline.py
+++ b/sdks/python/apache_beam/pipeline.py
@@ -235,10 +235,6 @@ class Pipeline(object):
@property # type: ignore[misc] # decorated property not supported
- @deprecated(
- since='First stable release',
- extra_message='References to <pipeline>.options'
- ' will not be supported')
def options(self):
# type: () -> PipelineOptions
return self._options
diff --git a/sdks/python/apache_beam/runners/interactive/interactive_beam.py
b/sdks/python/apache_beam/runners/interactive/interactive_beam.py
index 878552ef345..207b0f4e645 100644
--- a/sdks/python/apache_beam/runners/interactive/interactive_beam.py
+++ b/sdks/python/apache_beam/runners/interactive/interactive_beam.py
@@ -35,7 +35,6 @@ this module in your notebook or application code.
# pytype: skip-file
import logging
-import warnings
from datetime import timedelta
from typing import Dict
from typing import List
@@ -496,11 +495,6 @@ class Clusters:
dcm = self.pipelines.pop(p, None)
if dcm:
dcm.pipelines.remove(p)
- warnings.filterwarnings(
- 'ignore',
- 'options is deprecated since First stable release. References to '
- '<pipeline>.options will not be supported',
- category=DeprecationWarning)
p_flink_options = p.options.view_as(FlinkRunnerOptions)
p_flink_options.flink_master = '[auto]'
p_flink_options.flink_version = None
diff --git
a/sdks/python/apache_beam/runners/interactive/interactive_environment.py
b/sdks/python/apache_beam/runners/interactive/interactive_environment.py
index e508ce351ea..0e3d0060b1a 100644
--- a/sdks/python/apache_beam/runners/interactive/interactive_environment.py
+++ b/sdks/python/apache_beam/runners/interactive/interactive_environment.py
@@ -29,7 +29,6 @@ import importlib
import logging
import os
import tempfile
-import warnings
from collections.abc import Iterable
from pathlib import PurePath
@@ -374,11 +373,6 @@ class InteractiveEnvironment(object):
given pipeline. If the pipeline is absent from the environment while
create_if_absent is True, creates and returns a new file based cache
manager for the pipeline."""
- warnings.filterwarnings(
- 'ignore',
- 'options is deprecated since First stable release. References to '
- '<pipeline>.options will not be supported',
- category=DeprecationWarning)
cache_manager = self._cache_managers.get(str(id(pipeline)), None)
pipeline_runner = detect_pipeline_runner(pipeline)
diff --git a/sdks/python/apache_beam/runners/interactive/recording_manager.py
b/sdks/python/apache_beam/runners/interactive/recording_manager.py
index d123736233f..bee215717b4 100644
--- a/sdks/python/apache_beam/runners/interactive/recording_manager.py
+++ b/sdks/python/apache_beam/runners/interactive/recording_manager.py
@@ -448,11 +448,6 @@ class RecordingManager:
# incomplete.
self._clear()
- warnings.filterwarnings(
- 'ignore',
- 'options is deprecated since First stable release. References to '
- '<pipeline>.options will not be supported',
- category=DeprecationWarning)
cache_path = ie.current_env().options.cache_root
is_remote_run = cache_path and ie.current_env(
).options.cache_root.startswith('gs://')
