File tree 1 file changed +13
-7
lines changed
devcycle_python_sdk/managers
1 file changed +13
-7
lines changed Original file line number Diff line number Diff line change 2
2
3
3
import ld_eventsource
4
4
import ld_eventsource .actions
5
+ import logging
5
6
import ld_eventsource .config
6
7
from typing import Callable
7
8
9
+ logger = logging .getLogger (__name__ )
10
+
8
11
9
12
class SSEManager :
10
13
def __init__ (
@@ -31,13 +34,16 @@ def read_events(
31
34
handle_message : Callable [[ld_eventsource .actions .Event ], None ],
32
35
):
33
36
self .client .start ()
34
- for event in self .client .all :
35
- if isinstance (event , ld_eventsource .actions .Start ):
36
- handle_state (event )
37
- elif isinstance (event , ld_eventsource .actions .Fault ):
38
- handle_error (event )
39
- elif isinstance (event , ld_eventsource .actions .Event ):
40
- handle_message (event )
37
+ try :
38
+ for event in self .client .all :
39
+ if isinstance (event , ld_eventsource .actions .Start ):
40
+ handle_state (event )
41
+ elif isinstance (event , ld_eventsource .actions .Fault ):
42
+ handle_error (event )
43
+ elif isinstance (event , ld_eventsource .actions .Event ):
44
+ handle_message (event )
45
+ except Exception as e :
46
+ logger .exception (f"DevCycle: failed to read SSE message: { e } " )
41
47
42
48
def update (self , config : dict ):
43
49
if self .use_new_config (config ["sse" ]):
You can’t perform that action at this time.
0 commit comments