Removing Depreciation warning when using pipeline.options (#28774)

Co-authored-by: [email protected] <India@wc2019>

sdks/python/apache_beam/pipeline.py

@@ -235,10 +235,6 @@ def __init__(self, runner=None, options=None, argv=None):
 
 
   @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

sdks/python/apache_beam/runners/interactive/interactive_beam.py

@@ -35,7 +35,6 @@
 # pytype: skip-file
 
 import logging
-import warnings
 from datetime import timedelta
 from typing import Dict
 from typing import List
@@ -496,11 +495,6 @@ def cleanup(
       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

sdks/python/apache_beam/runners/interactive/interactive_environment.py

@@ -29,7 +29,6 @@
 import logging
 import os
 import tempfile
-import warnings
 from collections.abc import Iterable
 from pathlib import PurePath
 
@@ -374,11 +373,6 @@ def get_cache_manager(self, pipeline, create_if_absent=False):
     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)

sdks/python/apache_beam/runners/interactive/recording_manager.py

@@ -448,11 +448,6 @@ def record(self, pcolls, max_n, max_duration):
       # 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://')