diff --git a/sdks/python/apache_beam/io/gcp/bigtableio.py b/sdks/python/apache_beam/io/gcp/bigtableio.py index af289edc8b40..f41f802f733d 100644 --- a/sdks/python/apache_beam/io/gcp/bigtableio.py +++ b/sdks/python/apache_beam/io/gcp/bigtableio.py @@ -58,7 +58,7 @@ class _MutationsBatcher(MutationsBatcher): def __init__( self, table, flush_count=FLUSH_COUNT, max_row_bytes=MAX_ROW_BYTES): - super(_MutationsBatcher, self).__init__(table, flush_count, max_row_bytes) + super().__init__(table, flush_count, max_row_bytes) self.rows = [] def set_flush_callback(self, callback_fn): diff --git a/sdks/python/apache_beam/runners/interactive/pipeline_fragment_test.py b/sdks/python/apache_beam/runners/interactive/pipeline_fragment_test.py index cbd4e9b64b98..f1f423f97c0e 100644 --- a/sdks/python/apache_beam/runners/interactive/pipeline_fragment_test.py +++ b/sdks/python/apache_beam/runners/interactive/pipeline_fragment_test.py @@ -138,7 +138,7 @@ def test_pipeline_composites(self, cell): ib.watch({'p': p}) with cell: # Cell 2 - # pylint: disable=range-builtin-not-iterating + # pylint: disable=bad-option-value init = p | 'Init' >> beam.Create(range(5)) with cell: # Cell 3