File tree Expand file tree Collapse file tree 1 file changed +13
-7
lines changed
devcycle_python_sdk/managers Expand file tree Collapse file tree 1 file changed +13
-7
lines changed Original file line number Diff line number Diff line change 22
33import ld_eventsource
44import ld_eventsource .actions
5+ import logging
56import ld_eventsource .config
67from typing import Callable
78
9+ logger = logging .getLogger (__name__ )
10+
811
912class SSEManager :
1013 def __init__ (
@@ -31,13 +34,16 @@ def read_events(
3134 handlemessage : Callable [[ld_eventsource .actions .Event ], None ],
3235 ):
3336 self .client .start ()
34- for event in self .client .all :
35- if isinstance (event , ld_eventsource .actions .Start ):
36- handlestate (event )
37- elif isinstance (event , ld_eventsource .actions .Fault ):
38- handleerror (event )
39- elif isinstance (event , ld_eventsource .actions .Event ):
40- handlemessage (event )
37+ try :
38+ for event in self .client .all :
39+ if isinstance (event , ld_eventsource .actions .Start ):
40+ handlestate (event )
41+ elif isinstance (event , ld_eventsource .actions .Fault ):
42+ handleerror (event )
43+ elif isinstance (event , ld_eventsource .actions .Event ):
44+ handlemessage (event )
45+ except Exception as e :
46+ logger .exception (f"DevCycle: failed to read all events: { e } " )
4147
4248 def update (self , config : dict ):
4349 if self .use_new_config (config ["sse" ]):
You can’t perform that action at this time.
0 commit comments