chore: add more logging

balancednetwork · Nov 5, 2024 · 0555f63 · 0555f63
1 parent 18013cd
commit 0555f63
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/balanced_backend/cron/pool_series.py b/balanced_backend/cron/pool_series.py
@@ -132,6 +132,8 @@ def get_time_series_for_interval(session: 'Session', pool_volume: SeriesTable):
         pool_series = [i for i in last_volume_timeseries if i.pool_id == p][0]
         pool_volume.pool_close[p] = pool_series.open
 
+    logger.info(f"volume_time: {volume_time} - last_swap_time: {last_swap_time}")
+
     current_time = datetime.now().timestamp()
     head = False
     while volume_time < current_time + pool_volume.delta:
@@ -164,7 +166,7 @@ def get_time_series_for_interval(session: 'Session', pool_volume: SeriesTable):
         #  last total supply. This is definitely slow but might be faster in cluster.
 
         logger.info(f"Summarizing num swaps: {len(swaps)} at bh: {block_height} in "
-                    f"segment: {pool_volume.table_suffix}...")
+                    f"segment: {pool_volume.table_suffix} with timestamp: {volume_time}...")
 
         # Add any new pool IDs that need to be tracked
         new_pool_ids = set([