diff --git a/app/cron_market_maker.py b/app/cron_market_maker.py index 6b8b5d9..970af71 100644 --- a/app/cron_market_maker.py +++ b/app/cron_market_maker.py @@ -116,7 +116,7 @@ async def run(): tasks.append(process_ticker(ticker)) # Run tasks concurrently in batches to avoid too many open connections - batch_size = 10 # Adjust based on your system's capacity + batch_size = 1 # Adjust based on your system's capacity for i in tqdm(range(0, len(tasks), batch_size)): batch = tasks[i:i + batch_size] await asyncio.gather(*batch)