dwker/ttools
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ordering of remote files fix

Browse Source
This commit is contained in:
David Brazda
2024-11-21 05:28:08 +01:00
parent e22fda2f35
commit 0ff42e2345
2 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
setup.py
View File

@ -2,7 +2,7 @@ from setuptools import setup, find_packages
setup( setup(
name='ttools', name='ttools',
version='0.7.6', version='0.7.7',
packages=find_packages(), packages=find_packages(),
install_requires=[ install_requires=[
# list your dependencies here # list your dependencies here

12
ttools/loaders.py
View File

@ -357,6 +357,7 @@ def fetch_trades_parallel(symbol, start_date, end_date, exclude_conditions = EXC
#do this only for remotes #do this only for remotes
if len(days_from_remote) > 0: if len(days_from_remote) > 0:
with ThreadPoolExecutor(max_workers=max_workers) as executor: with ThreadPoolExecutor(max_workers=max_workers) as executor:
futures_with_date = []
#for single_date in (start_date + timedelta(days=i) for i in range((end_date - start_date).days + 1)): #for single_date in (start_date + timedelta(days=i) for i in range((end_date - start_date).days + 1)):
for market_day in tqdm(days_from_remote, desc=f"{symbol} Remote fetching"): for market_day in tqdm(days_from_remote, desc=f"{symbol} Remote fetching"):
#start = datetime.combine(single_date, time(9, 30)) # Market opens at 9:30 AM #start = datetime.combine(single_date, time(9, 30)) # Market opens at 9:30 AM
@ -379,14 +380,19 @@ def fetch_trades_parallel(symbol, start_date, end_date, exclude_conditions = EXC
end = min(end_date, max_day_time) end = min(end_date, max_day_time)
future = executor.submit(fetch_daily_stock_trades, symbol, start, end, exclude_conditions, minsize, main_session_only, no_return, force_remote) future = executor.submit(fetch_daily_stock_trades, symbol, start, end, exclude_conditions, minsize, main_session_only, no_return, force_remote)
futures.append(future) futures_with_date.append((future,start))
for future in tqdm(futures, desc=f"{symbol} Receiving trades"): results_with_dates = []
for future, date in tqdm(futures_with_date, desc=f"{symbol} Receiving trades"):
try: try:
result = future.result() result = future.result()
results.append(result) if result is not None:
results_with_dates.append((result,date))
except Exception as e: except Exception as e:
print(f"Error fetching data for a day: {e}") print(f"Error fetching data for a day: {e}")
# Sort by date before concatenating
results_with_dates.sort(key=lambda x: x[1])
results = [r for r, _ in results_with_dates]
if not no_return: if not no_return:
# Batch concatenation to improve speed # Batch concatenation to improve speed