Skip to content

Commit 30be6fa

Browse files
author
Bilal Al
committed
cleanup
1 parent 55a441c commit 30be6fa

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

splitio/sync/synchronizer.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -257,7 +257,6 @@ def __init__(self, split_synchronizers, split_tasks):
257257
self._periodic_data_recording_tasks.append(self._split_tasks.unique_keys_task)
258258
if self._split_tasks.clear_filter_task:
259259
self._periodic_data_recording_tasks.append(self._split_tasks.clear_filter_task)
260-
self._break_sync_all = False
261260

262261
@property
263262
def split_sync(self):
@@ -398,7 +397,6 @@ def synchronize_splits(self, till, sync_segments=True):
398397
:returns: whether the synchronization was successful or not.
399398
:rtype: bool
400399
"""
401-
self._break_sync_all = False
402400
_LOGGER.debug('Starting feature flags synchronization')
403401
try:
404402
new_segments = []
@@ -454,7 +452,7 @@ def sync_all(self, max_retry_attempts=_SYNC_ALL_NO_RETRIES):
454452
_LOGGER.debug('Error: ', exc_info=True)
455453
if max_retry_attempts != _SYNC_ALL_NO_RETRIES:
456454
retry_attempts += 1
457-
if retry_attempts > max_retry_attempts or self._break_sync_all:
455+
if retry_attempts > max_retry_attempts:
458456
break
459457
how_long = self._backoff.get()
460458
time.sleep(how_long)

0 commit comments

Comments
 (0)