[BEAM-13051] Fixed no-value-for-parameter warning for missing default…

… values
apache · Jan 21, 2022 · 6000dc1 · 6000dc1
1 parent 12253cb
commit 6000dc1
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/sdks/python/apache_beam/io/avroio_test.py b/sdks/python/apache_beam/io/avroio_test.py
@@ -95,7 +95,13 @@ def tearDown(self):
         os.remove(path)
     self._temp_files = []
 
-  def _write_data(self, directory, prefix, codec, count, sync_interval):
+  def _write_data(
+      self,
+      directory=None,
+      prefix=None,
+      codec=None,
+      count=None,
+      sync_interval=None):
     raise NotImplementedError
 
   def _write_pattern(self, num_files, return_filenames=False):

diff --git a/sdks/python/apache_beam/io/filesystem.py b/sdks/python/apache_beam/io/filesystem.py
@@ -257,7 +257,7 @@ def _read_from_internal_buffer(self, read_fn):
     self._read_buffer.seek(0, os.SEEK_END)  # Allow future writes.
     return result
 
-  def read(self, num_bytes):
+  def read(self, num_bytes=None):
     # type: (int) -> bytes
     if not self._decompressor:
       raise ValueError('decompressor not initialized')

diff --git a/sdks/python/apache_beam/testing/load_tests/load_test_metrics_utils.py b/sdks/python/apache_beam/testing/load_tests/load_test_metrics_utils.py
@@ -216,7 +216,7 @@ def __init__(
           'InfluxDB')
     self.filters = filters
 
-  def publish_metrics(self, result, extra_metrics: dict):
+  def publish_metrics(self, result, extra_metrics: dict = None):
     metric_id = uuid.uuid4().hex
     metrics = result.metrics().query(self.filters)