AmineTMIRI/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update cron job

Browse Source
This commit is contained in:
MuslemRahimi 2024-07-05 22:38:04 +02:00
parent 19300ddda6
commit acc8faa406
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/cron_market_maker.py
View File

@ -116,7 +116,7 @@ async def run():
tasks.append(process_ticker(ticker)) tasks.append(process_ticker(ticker))
# Run tasks concurrently in batches to avoid too many open connections # 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)): for i in tqdm(range(0, len(tasks), batch_size)):
batch = tasks[i:i + batch_size] batch = tasks[i:i + batch_size]
await asyncio.gather(*batch) await asyncio.gather(*batch)