File tree Expand file tree Collapse file tree 2 files changed +11
-4
lines changed Expand file tree Collapse file tree 2 files changed +11
-4
lines changed Original file line number Diff line number Diff line change @@ -38,8 +38,11 @@ def _poll(self):
38
38
log .info ("PollingUpdateProcessor initialized ok" )
39
39
self ._ready .set ()
40
40
except UnsuccessfulResponseException as e :
41
- log .error (http_error_message (e .status , "polling request" ))
42
- if not is_http_error_recoverable (e .status ):
41
+ http_error_message_result = http_error_message (e .status , "polling request" )
42
+ if is_http_error_recoverable (e .status ):
43
+ log .warning (http_error_message_result )
44
+ else :
45
+ log .error (http_error_message_result )
43
46
self ._ready .set () # if client is initializing, make it stop waiting; has no effect if already inited
44
47
self .stop ()
45
48
except Exception as e :
Original file line number Diff line number Diff line change @@ -83,10 +83,14 @@ def run(self):
83
83
log .info ("StreamingUpdateProcessor initialized ok." )
84
84
self ._ready .set ()
85
85
except UnsuccessfulResponseException as e :
86
- log .error (http_error_message (e .status , "stream connection" ))
87
86
self ._record_stream_init (True )
88
87
self ._es_started = None
89
- if not is_http_error_recoverable (e .status ):
88
+
89
+ http_error_message_result = http_error_message (e .status , "stream connection" )
90
+ if is_http_error_recoverable (e .status ):
91
+ log .warning (http_error_message_result )
92
+ else :
93
+ log .error (http_error_message_result )
90
94
self ._ready .set () # if client is initializing, make it stop waiting; has no effect if already inited
91
95
self .stop ()
92
96
break
You can’t perform that action at this time.
0 commit comments