File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 1818
1919logging .basicConfig (level = logging .INFO )
2020logging .getLogger ("pika" ).setLevel (logging .WARN )
21+ logger = logging .getLogger (__name__ )
2122
2223T = TypeVar ('T' )
2324
@@ -80,7 +81,7 @@ def serve(self) -> NoReturn:
8081 self .on_server_rx_rpc_request ,
8182 consumer_tag = self .server_name ,
8283 )
83- logging .info ("Ready, waiting on work on %s" , self .server_queue )
84+ logger .info ("Ready, waiting on work on %s" , self .server_queue )
8485 channel .start_consuming ()
8586
8687 def on_server_rx_rpc_request (
@@ -91,14 +92,14 @@ def on_server_rx_rpc_request(
9192 _body : str ,
9293 ) -> None :
9394 body = dill .loads (_body )
94- logging .info ("RPC Server got request: %s" , body )
95+ logger .info ("RPC Server got request: %s" , body )
9596
9697 res = {"key" : body ["key" ]}
9798
9899 try :
99100 res ["body" ] = self ._methods [body ["method" ]](* body ["args" ], ** body ["kwargs" ])
100101 except Exception as e :
101- logging .exception ("Call to %s caused exception" , body ["method" ])
102+ logger .exception ("Call to %s caused exception" , body ["method" ])
102103 res ["exception" ] = e
103104
104105 ch .basic_publish ("" , routing_key = properties .reply_to , body = dill .dumps (res ))
You can’t perform that action at this time.
0 commit comments