Resetting utils subtree.

2025-01-03 18:33:26 +05:30
parent 6c4f55d17e
commit 49827faee6
179 changed files with 6 additions and 138699 deletions
@@ -161,7 +161,7 @@ def ticks_to_kafka(ticks: List[TradingTick]) -> int:
        # Flush the existing messages if needed:
        TOTAL_TICK_COUNT += 1
        TICKS_SINCE_FLUSH += 1
-        if TICKS_SINCE_FLUSH > 50_000:
+        if TICKS_SINCE_FLUSH > 5_000:
            kafka_producer.flush()
            TICKS_SINCE_FLUSH = 0