Skip to content

Commit 0539143

Browse files
author
Bilal Al
committed
moved asyncio dependencies to a section
1 parent 56c4893 commit 0539143

File tree

2 files changed

+5
-14
lines changed

2 files changed

+5
-14
lines changed

setup.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,7 @@
2222
'pyyaml',
2323
'docopt>=0.6.2',
2424
'enum34;python_version<"3.4"',
25-
'bloom-filter2>=2.0.0',
26-
'aiohttp>=3.8.4',
27-
'aiofiles>=23.1.0'
25+
'bloom-filter2>=2.0.0'
2826
]
2927

3028
with open(path.join(path.abspath(path.dirname(__file__)), 'splitio', 'version.py')) as f:
@@ -45,7 +43,8 @@
4543
'test': TESTS_REQUIRES,
4644
'redis': ['redis>=2.10.5'],
4745
'uwsgi': ['uwsgi>=2.0.0'],
48-
'cpphash': ['mmh3cffi==0.2.1']
46+
'cpphash': ['mmh3cffi==0.2.1'],
47+
'asyncio': ['aiohttp>=3.8.4', 'aiofiles>=23.1.0']
4948
},
5049
setup_requires=['pytest-runner', 'pluggy==1.0.0;python_version<"3.8"'],
5150
classifiers=[

splitio/sync/synchronizer.py

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -266,14 +266,6 @@ def split_sync(self):
266266
def segment_storage(self):
267267
return self._split_synchronizers.segment_sync._segment_storage
268268

269-
@property
270-
def split_sync(self):
271-
return self._split_synchronizers.split_sync
272-
273-
@property
274-
def segment_storage(self):
275-
return self._split_synchronizers.segment_sync._segment_storage
276-
277269
def synchronize_segment(self, segment_name, till):
278270
"""
279271
Synchronize particular segment.
@@ -566,8 +558,8 @@ async def synchronize_splits(self, till, sync_segments=True):
566558
try:
567559
new_segments = []
568560
for segment in await self._split_synchronizers.split_sync.synchronize_splits(till):
569-
if not await self._split_synchronizers.segment_sync.segment_exist_in_storage(segment):
570-
new_segments.append(segment)
561+
if not await self._split_synchronizers.segment_sync.segment_exist_in_storage(segment):
562+
new_segments.append(segment)
571563
if sync_segments and len(new_segments) != 0:
572564
_LOGGER.debug('Synching Segments: %s', ','.join(new_segments))
573565
success = await self._split_synchronizers.segment_sync.synchronize_segments(new_segments, True)

0 commit comments

Comments
 (0)