fix lint

apache · Oct 20, 2020 · a8a5b08 · a8a5b08
1 parent 25642d1
commit a8a5b08
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/sdks/python/apache_beam/io/iobase.py b/sdks/python/apache_beam/io/iobase.py
@@ -1367,7 +1367,6 @@ def with_completed(self, completed):
 class _SDFBoundedSourceRestriction(object):
  """ A restriction wraps SourceBundle and RangeTracker. """
  def __init__(self, source_bundle, range_tracker=None):
- _LOGGER.error("migryz>>>> source_bundle: %s, range_tracker: %s", source_bundle, range_tracker)
  self._source_bundle = source_bundle
  self._range_tracker = range_tracker
 
@@ -1378,8 +1377,7 @@ def __reduce__(self):
  def range_tracker(self):
  if not self._range_tracker:
  self._range_tracker = self._source_bundle.source.get_range_tracker(
- self._source_bundle.start_position,
- self._source_bundle.stop_position)
+ self._source_bundle.start_position, self._source_bundle.stop_position)
  return self._range_tracker
 
  def weight(self):
@@ -1426,7 +1424,6 @@ class _SDFBoundedSourceRestrictionTracker(RestrictionTracker):
  Delegated RangeTracker guarantees synchronization safety.
  """
  def __init__(self, restriction):
- _LOGGER.error("migryz>>>> restriction: %s, type: %s", restriction, type(restriction))
  if not isinstance(restriction, _SDFBoundedSourceRestriction):
  raise ValueError(
  'Initializing SDFBoundedSourceRestrictionTracker'