From a8a5b08a0456130dd050c7ff9b98af443aee6d9f Mon Sep 17 00:00:00 2001 From: Pablo Estrada Date: Tue, 20 Oct 2020 14:15:44 -0700 Subject: [PATCH] fix lint --- sdks/python/apache_beam/io/iobase.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/sdks/python/apache_beam/io/iobase.py b/sdks/python/apache_beam/io/iobase.py index cc547933f3854..f7c6752485e97 100644 --- 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'