@@ -324,7 +324,9 @@ def run(self) -> None:
324324 sys .exit (0 )
325325 except Exception as err : # pylint: disable=broad-except
326326 self .pika_connection .close ()
327- self .helper .connector_logger .error (str (err ))
327+ self .helper .connector_logger .error (
328+ type (err ).__name__ , {"reason" : str (err )}
329+ )
328330 sys .exit (1 )
329331
330332 def stop (self ):
@@ -367,12 +369,12 @@ def ping(self) -> None:
367369 )
368370 if self .in_error :
369371 self .in_error = False
370- self .connector_logger .error ("API Ping back to normal" )
372+ self .connector_logger .info ("API Ping back to normal" )
371373 self .metric .inc ("ping_api_count" )
372- except Exception : # pylint: disable=broad-except
374+ except Exception as e : # pylint: disable=broad-except
373375 self .in_error = True
374376 self .metric .inc ("ping_api_error" )
375- self .connector_logger .error ("Error pinging the API" )
377+ self .connector_logger .error ("Error pinging the API" , { "reason" : str ( e )} )
376378 self .exit_event .wait (40 )
377379
378380 def run (self ) -> None :
@@ -818,9 +820,9 @@ def force_ping(self):
818820 )
819821 if initial_state != remote_state :
820822 self .api .connector .ping (self .connector_id , initial_state )
821- except Exception : # pylint: disable=broad-except
823+ except Exception as e : # pylint: disable=broad-except
822824 self .metric .inc ("error_count" )
823- self .connector_logger .error ("Error pinging the API" )
825+ self .connector_logger .error ("Error pinging the API" , { "reason" : str ( e )} )
824826
825827 def listen (self , message_callback : Callable [[Dict ], str ]) -> None :
826828 """listen for messages and register callback function
0 commit comments