diff --git a/sdks/python/apache_beam/coders/coder_impl.py b/sdks/python/apache_beam/coders/coder_impl.py index e44c2535156e5..ff5fb5bef7ac9 100644 --- a/sdks/python/apache_beam/coders/coder_impl.py +++ b/sdks/python/apache_beam/coders/coder_impl.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """Coder implementations. The actual encode/decode implementations are split off from coders to diff --git a/sdks/python/apache_beam/coders/stream.pyx b/sdks/python/apache_beam/coders/stream.pyx index 8f941c151bde7..3977660f68b06 100644 --- a/sdks/python/apache_beam/coders/stream.pyx +++ b/sdks/python/apache_beam/coders/stream.pyx @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """Compiled version of the Stream objects used by CoderImpl. For internal use only; no backwards-compatibility guarantees. diff --git a/sdks/python/apache_beam/metrics/cells.py b/sdks/python/apache_beam/metrics/cells.py index 53b6fc8495920..3bfbfc6b2e773 100644 --- a/sdks/python/apache_beam/metrics/cells.py +++ b/sdks/python/apache_beam/metrics/cells.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """ This file contains metric cell classes. A metric cell is used to accumulate in-memory changes to a metric. It represents a specific metric in a single diff --git a/sdks/python/apache_beam/metrics/execution.py b/sdks/python/apache_beam/metrics/execution.py index 4202f7996c7fd..570062371cae6 100644 --- a/sdks/python/apache_beam/metrics/execution.py +++ b/sdks/python/apache_beam/metrics/execution.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """ This module is for internal use only; no backwards-compatibility guarantees. diff --git a/sdks/python/apache_beam/metrics/monitoring_infos.py b/sdks/python/apache_beam/metrics/monitoring_infos.py index 7bc7cced280c1..0e638c9eb4fe7 100644 --- a/sdks/python/apache_beam/metrics/monitoring_infos.py +++ b/sdks/python/apache_beam/metrics/monitoring_infos.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - # pytype: skip-file import collections diff --git a/sdks/python/apache_beam/runners/common.py b/sdks/python/apache_beam/runners/common.py index 40a3341e2b4c3..ba4dd98c7a937 100644 --- a/sdks/python/apache_beam/runners/common.py +++ b/sdks/python/apache_beam/runners/common.py @@ -14,7 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. # -# cython: language_level=3 """Worker operations executor. diff --git a/sdks/python/apache_beam/runners/worker/logger.py b/sdks/python/apache_beam/runners/worker/logger.py index 1efebeb3c78c0..06e2508fb7d29 100644 --- a/sdks/python/apache_beam/runners/worker/logger.py +++ b/sdks/python/apache_beam/runners/worker/logger.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """Python worker logging.""" # pytype: skip-file diff --git a/sdks/python/apache_beam/runners/worker/opcounters.py b/sdks/python/apache_beam/runners/worker/opcounters.py index ba53cbcbce7f5..51ca4cf0545b7 100644 --- a/sdks/python/apache_beam/runners/worker/opcounters.py +++ b/sdks/python/apache_beam/runners/worker/opcounters.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """Counters collect the progress of the Worker for reporting to the service.""" # pytype: skip-file diff --git a/sdks/python/apache_beam/runners/worker/operations.py b/sdks/python/apache_beam/runners/worker/operations.py index 00a652c49e669..58c807c28dbd4 100644 --- a/sdks/python/apache_beam/runners/worker/operations.py +++ b/sdks/python/apache_beam/runners/worker/operations.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """Worker operations executor.""" # pytype: skip-file diff --git a/sdks/python/apache_beam/runners/worker/statesampler_fast.pyx b/sdks/python/apache_beam/runners/worker/statesampler_fast.pyx index 7c082b7a62269..d02d05c3af942 100644 --- a/sdks/python/apache_beam/runners/worker/statesampler_fast.pyx +++ b/sdks/python/apache_beam/runners/worker/statesampler_fast.pyx @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """State sampler for tracking time spent in execution steps. The state sampler profiles the time spent in each step of a pipeline. diff --git a/sdks/python/apache_beam/testing/fast_test_utils.pyx b/sdks/python/apache_beam/testing/fast_test_utils.pyx index d78a5b773186f..d815bcfe8f966 100644 --- a/sdks/python/apache_beam/testing/fast_test_utils.pyx +++ b/sdks/python/apache_beam/testing/fast_test_utils.pyx @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - cimport libc.stdint cimport libc.stdlib cimport libc.string diff --git a/sdks/python/apache_beam/transforms/cy_combiners.py b/sdks/python/apache_beam/transforms/cy_combiners.py index 2267d02c1908c..b5cc7493a29a3 100644 --- a/sdks/python/apache_beam/transforms/cy_combiners.py +++ b/sdks/python/apache_beam/transforms/cy_combiners.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """A library of basic cythonized CombineFn subclasses. For internal use only; no backwards-compatibility guarantees. diff --git a/sdks/python/apache_beam/transforms/cy_dataflow_distribution_counter.pyx b/sdks/python/apache_beam/transforms/cy_dataflow_distribution_counter.pyx index c1b32356ed1ff..c117ae32f4e5f 100644 --- a/sdks/python/apache_beam/transforms/cy_dataflow_distribution_counter.pyx +++ b/sdks/python/apache_beam/transforms/cy_dataflow_distribution_counter.pyx @@ -14,8 +14,6 @@ # limitations under the License. # -# cython: language_level=3 - """ For internal use only. No backwards compatibility guarantees.""" cimport cython diff --git a/sdks/python/apache_beam/transforms/stats.py b/sdks/python/apache_beam/transforms/stats.py index 2599760f8d5be..d389463e55a26 100644 --- a/sdks/python/apache_beam/transforms/stats.py +++ b/sdks/python/apache_beam/transforms/stats.py @@ -15,8 +15,6 @@ # limitations under the License. # -# cython: language_level=3 - """This module has all statistic related transforms. This ApproximateUnique class will be deprecated [1]. PLease look into using diff --git a/sdks/python/apache_beam/utils/counters.py b/sdks/python/apache_beam/utils/counters.py index 214fa433de1c4..57d73fa283ebf 100644 --- a/sdks/python/apache_beam/utils/counters.py +++ b/sdks/python/apache_beam/utils/counters.py @@ -17,7 +17,6 @@ # cython: profile=False # cython: overflowcheck=True -# cython: language_level=3 """Counters collect the progress of the Worker for reporting to the service. diff --git a/sdks/python/apache_beam/utils/windowed_value.py b/sdks/python/apache_beam/utils/windowed_value.py index fb15d3778a6a0..f6232ce2f6b0d 100644 --- a/sdks/python/apache_beam/utils/windowed_value.py +++ b/sdks/python/apache_beam/utils/windowed_value.py @@ -22,8 +22,6 @@ # editing this file as WindowedValues are created for every element for # every step in a Beam pipeline. -# cython: language_level=3 - # pytype: skip-file import collections