consolidate() loads all pending hot-tier rows into memory at once (up to CONSOLIDATION_BATCH_SIZE). For agents with 10K+ events this causes high memory usage. Use cursor-based pagination to process 50 rows at a time with per-batch transactions. See BACKLOG.md #6.
consolidate() loads all pending hot-tier rows into memory at once (up to CONSOLIDATION_BATCH_SIZE). For agents with 10K+ events this causes high memory usage. Use cursor-based pagination to process 50 rows at a time with per-batch transactions. See BACKLOG.md #6.