1010 sync as get_feature_config
1111from .api .default .get_segment_by_identifier import sync as get_target_segment
1212from .config import Config
13- from .interface import Cache
1413from .models .message import Message
1514from .sse_client import SSEClient
1615from .util import log
1716
1817
1918class StreamProcessor (Thread ):
20- def __init__ (self , repository : DataProviderInterface , client : AuthenticatedClient ,
19+ def __init__ (self , repository : DataProviderInterface ,
20+ client : AuthenticatedClient ,
2121 environment_id : str , api_key : str , token : str ,
2222 config : Config , ready : threading .Event ,
2323 cluster : str ):
@@ -90,7 +90,8 @@ def stop(self):
9090
9191class FlagMsgProcessor (Thread ):
9292
93- def __init__ (self , repository : DataProviderInterface , client : AuthenticatedClient ,
93+ def __init__ (self , repository : DataProviderInterface ,
94+ client : AuthenticatedClient ,
9495 environment_id : str , msg : Message ):
9596 Thread .__init__ (self )
9697 self ._repository = repository
@@ -115,7 +116,8 @@ def run(self):
115116
116117class SegmentMsgProcessor (Thread ):
117118
118- def __init__ (self , repository : DataProviderInterface , client : AuthenticatedClient ,
119+ def __init__ (self , repository : DataProviderInterface ,
120+ client : AuthenticatedClient ,
119121 environment_id : str , msg : Message ):
120122 Thread .__init__ (self )
121123 self ._repository = repository
0 commit comments