Skip to content

Commit

Permalink
Fix / Bamboo Relay, Loopring, Radar Relay debug logging outputs
Browse files Browse the repository at this point in the history
  • Loading branch information
TheHolyRoger committed Apr 1, 2021
1 parent e742a34 commit 4606e0e
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -130,10 +130,8 @@ async def _order_book_diff_router(self):
# Log some statistics.
now: float = time.time()
if int(now / 60.0) > int(last_message_timestamp / 60.0):
self.logger().debug("Diff messages processed: %d, rejected: %d, queued: %d",
messages_accepted,
messages_rejected,
messages_queued)
self.logger().debug(f"Diff messages processed: {messages_accepted}, "
f"rejected: {messages_rejected}, queued: {messages_queued}")
messages_accepted = 0
messages_rejected = 0
messages_queued = 0
Expand Down Expand Up @@ -175,7 +173,7 @@ async def _track_single_book(self, trading_pair: str):
s_bids, s_asks = active_order_tracker.convert_snapshot_message_to_order_book_row(message)
order_book.apply_snapshot(s_bids, s_asks, message.update_id)

self.logger().debug("Processed order book snapshot for %s.", trading_pair)
self.logger().debug(f"Processed order book snapshot for {trading_pair}.")
except asyncio.CancelledError:
raise
except Exception:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ async def _track_single_book(self, trading_pair: str):
elif message.type is OrderBookMessageType.SNAPSHOT:
s_bids, s_asks = active_order_tracker.convert_snapshot_message_to_order_book_row(message)
order_book.apply_snapshot(s_bids, s_asks, message.timestamp)
self.logger().debug("Processed order book snapshot for %s.", trading_pair)
self.logger().debug(f"Processed order book snapshot for {trading_pair}.")

except asyncio.CancelledError:
raise
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -128,10 +128,8 @@ async def _order_book_diff_router(self):
# Log some statistics.
now: float = time.time()
if int(now / 60.0) > int(last_message_timestamp / 60.0):
self.logger().debug("Diff messages processed: %d, rejected: %d, queued: %d",
messages_accepted,
messages_rejected,
messages_queued)
self.logger().debug(f"Diff messages processed: {messages_accepted}, "
f"rejected: {messages_rejected}, queued: {messages_queued}")
messages_accepted = 0
messages_rejected = 0
messages_queued = 0
Expand Down Expand Up @@ -179,8 +177,7 @@ async def _track_single_book(self, trading_pair: str):
# Output some statistics periodically.
now: float = time.time()
if int(now / 60.0) > int(last_message_timestamp / 60.0):
self.logger().debug("Processed %d order book diffs for %s.",
diff_messages_accepted, trading_pair)
self.logger().debug(f"Processed {diff_messages_accepted} order book diffs for {trading_pair}.")
diff_messages_accepted = 0
last_message_timestamp = now
elif message.type is OrderBookMessageType.SNAPSHOT:
Expand All @@ -194,7 +191,7 @@ async def _track_single_book(self, trading_pair: str):
d_bids, d_asks = active_order_tracker.convert_diff_message_to_order_book_row(diff_message)
order_book.apply_diffs(d_bids, d_asks, diff_message.update_id)

self.logger().debug("Processed order book snapshot for %s.", trading_pair)
self.logger().debug(f"Processed order book snapshot for {trading_pair}.")
except asyncio.CancelledError:
raise
except Exception:
Expand Down

0 comments on commit 4606e0e

Please sign in to comment.