Skip to content

Commit a0d9f0e

Browse files
committed
flip print statements to logger messages
Signed-off-by: Michael Oviedo <mikeovi@amazon.com>
1 parent 0b0049d commit a0d9f0e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

osbenchmark/worker_coordinator/worker_coordinator.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -340,7 +340,7 @@ def scale_up(self):
340340
break
341341

342342
if not client_activated:
343-
print("No inactive clients found to activate")
343+
self.logger.info("No inactive clients found to activate")
344344
finally:
345345
self.state = FeedbackState.NEUTRAL
346346

@@ -350,7 +350,7 @@ def receiveMsg_SharedClientStateMessage(self, msg, sender):
350350
self.total_client_count += len(msg.dictionary)
351351
self.handle_state()
352352
except Exception as e:
353-
print("Error processing client states: %s", e)
353+
self.logger.error("Error processing client states: %s", e)
354354

355355
def receiveMsg_StartFeedbackActor(self, msg, sender):
356356
self.wakeupAfter(datetime.timedelta(seconds=FeedbackActor.WAKEUP_INTERVAL))
@@ -362,7 +362,7 @@ def receiveMsg_WakeupMessage(self, msg, sender):
362362
self.wakeupAfter(datetime.timedelta(seconds=FeedbackActor.WAKEUP_INTERVAL))
363363

364364
def receiveUnrecognizedMessage(self, msg, sender):
365-
print("Received unrecognized message: %s", msg)
365+
self.logger.info("Received unrecognized message: %s", msg)
366366

367367
class WorkerCoordinatorActor(actor.BenchmarkActor):
368368
RESET_RELATIVE_TIME_MARKER = "reset_relative_time"

0 commit comments

Comments
 (0)