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

update borrowed share

Browse Source
This commit is contained in:
MuslemRahimi 2024-08-27 22:16:58 +02:00
parent 7669f2ac4b
commit e7b85f37ac
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_borrowed_share.py
View File

@ -53,7 +53,7 @@ async def run():
con.close() con.close()
etf_con.close() etf_con.close()
total_symbols = stocks_symbols #['AAPL', 'NVDA', 'GME','PLTR','AMC'] #stocks_symbols + etf_symbols total_symbols = stocks_symbols #+ etf_symbols
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
tasks = [] tasks = []
@ -61,11 +61,11 @@ 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 = 3 # 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)
await asyncio.sleep(60) await asyncio.sleep(5)
if __name__ == "__main__": if __name__ == "__main__":
try: try: