Skip to content

Commit 702d309

Browse files
committed
refactor workers
1 parent 2abbec7 commit 702d309

File tree

5 files changed

+4
-287
lines changed

5 files changed

+4
-287
lines changed

splitio/push/processor.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@
33
from queue import Queue
44

55
from splitio.push.parser import UpdateType
6-
from splitio.push.splitworker import SplitWorker
7-
from splitio.push.segmentworker import SegmentWorker
6+
from splitio.push.workers import SplitWorker
7+
from splitio.push.workers import SegmentWorker
88

99

1010
class MessageProcessor(object):

splitio/push/segmentworker.py

Lines changed: 0 additions & 142 deletions
This file was deleted.

splitio/push/splitworker.py

Lines changed: 0 additions & 141 deletions
This file was deleted.

tests/push/test_segment_worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import pytest
55

66
from splitio.api import APIException
7-
from splitio.push.segmentworker import SegmentWorker, SegmentWorkerAsync
7+
from splitio.push.workers import SegmentWorker, SegmentWorkerAsync
88
from splitio.models.notification import SegmentChangeNotification
99
from splitio.optional.loaders import asyncio
1010

tests/push/test_split_worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import pytest
55

66
from splitio.api import APIException
7-
from splitio.push.splitworker import SplitWorker, SplitWorkerAsync
7+
from splitio.push.workers import SplitWorker, SplitWorkerAsync
88
from splitio.models.notification import SplitChangeNotification
99
from splitio.optional.loaders import asyncio
1010

0 commit comments

Comments
 (0)