@@ -130,7 +130,7 @@ def _signal_handler_setup(self):
130
130
Define how to handle signal interrupts
131
131
"""
132
132
def term_handler (_ , __ ):
133
- self .logger .info ("Term handler" )
133
+ self .logger .debug ("Term handler" )
134
134
pp_handler = self .state .get_corresponding_handler (PoisonPillMessage ())
135
135
pp_handler .handle (PoisonPillMessage (soft = False ))
136
136
self ._kill_process ()
@@ -154,7 +154,7 @@ def _setup(self):
154
154
155
155
self .socket_interface .setup ()
156
156
157
- self .logger .info (self .name + ' process created.' )
157
+ self .logger .debug (self .name + ' process created.' )
158
158
159
159
self ._signal_handler_setup ()
160
160
@@ -214,7 +214,7 @@ def _kill_process(self):
214
214
Kill the actor (close sockets)
215
215
"""
216
216
self .socket_interface .close ()
217
- self .logger .info (self .name + " teardown" )
217
+ self .logger .debug (self .name + " teardown" )
218
218
219
219
def connect_data (self ):
220
220
"""
@@ -238,7 +238,7 @@ def send_control(self, msg):
238
238
:param Object msg: the message to send to this actor
239
239
"""
240
240
self .socket_interface .send_control (msg )
241
- self .logger .info ('send control [' + str (msg ) + '] to ' + self .name )
241
+ self .logger .debug ('send control [' + str (msg ) + '] to ' + self .name )
242
242
243
243
def receive_control (self , timeout = None ):
244
244
"""
@@ -248,7 +248,7 @@ def receive_control(self, timeout=None):
248
248
timeout = self .socket_interface .timeout
249
249
250
250
msg = self .socket_interface .receive_control (timeout )
251
- self .logger .info ("receive control : [" + str (msg ) + "]" )
251
+ self .logger .debug ("receive control : [" + str (msg ) + "]" )
252
252
return msg
253
253
254
254
def send_data (self , msg ):
@@ -258,7 +258,7 @@ def send_data(self, msg):
258
258
:param Object msg: the message to send to this actor
259
259
"""
260
260
self .socket_interface .send_data (msg )
261
- self .logger .info ('send data [' + str (msg ) + '] to ' + self .name )
261
+ self .logger .debug ('send data [' + str (msg ) + '] to ' + self .name )
262
262
263
263
def receive (self ):
264
264
"""
@@ -269,7 +269,7 @@ def receive(self):
269
269
:rtype: a list of Object
270
270
"""
271
271
msg = self .socket_interface .receive ()
272
- self .logger .info ("receive data : [" + str (msg ) + "]" )
272
+ self .logger .debug ("receive data : [" + str (msg ) + "]" )
273
273
return msg
274
274
275
275
def soft_kill (self ):
0 commit comments