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-09-22 01:35:25 +02:00
parent 937086c420
commit 1621339ac2
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/cron_historical_price.py
View File

@ -111,8 +111,8 @@ async def run():
for i in range(0, len(total_symbols), chunk_size): for i in range(0, len(total_symbols), chunk_size):
symbols_chunk = total_symbols[i:i + chunk_size] symbols_chunk = total_symbols[i:i + chunk_size]
await fetch_and_save_symbols_data(symbols_chunk, etf_symbols, crypto_symbols, session) await fetch_and_save_symbols_data(symbols_chunk, etf_symbols, crypto_symbols, session)
print('sleeping for 60 sec') print('sleeping for 30 sec')
await asyncio.sleep(60) # Wait for 60 seconds between chunks await asyncio.sleep(30) # Wait for 60 seconds between chunks
except Exception as e: except Exception as e:
print(f"Failed to run fetch and save data: {e}") print(f"Failed to run fetch and save data: {e}")
@ -131,7 +131,7 @@ try:
end_date = end_date.strftime("%Y-%m-%d") end_date = end_date.strftime("%Y-%m-%d")
chunk_size = 250 chunk_size = 400
asyncio.run(run()) asyncio.run(run())
con.close() con.close()
etf_con.close() etf_con.close()