krumbelfix/trading-daemon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updated dashboard
All checks were successful
Deployment / deploy-docker (push) Successful in 18s
Details

Browse Source
This commit is contained in:
Melchior Reimers
2026-01-27 13:08:14 +01:00
parent 996cf0b1a1
commit f3a59ac778
3 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
dashboard/__pycache__/server.cpython-313.pyc Normal file
View File

Binary file not shown.

BIN
src/analytics/__pycache__/worker.cpython-313.pyc Normal file
View File

Binary file not shown.

19
src/analytics/worker.py
View File

@@ -665,8 +665,7 @@ class AnalyticsWorker:
logger.info(f"Processing yesterday's data: {yesterday}")
self.process_date(yesterday)
# Heute wird nur verarbeitet, wenn es bereits Trades gibt (normalerweise am Ende des Tages)
# Aber wir prüfen trotzdem, ob es Daten gibt
# Heute wird verarbeitet, wenn es bereits Trades gibt
if today not in existing_dates:
# Prüfe ob es heute schon Trades gibt
query = f"select count(*) from trades where date_trunc('day', timestamp) = '{today}'"
@@ -674,6 +673,8 @@ class AnalyticsWorker:
if data and data.get('dataset') and data['dataset'][0][0] and data['dataset'][0][0] > 0:
logger.info(f"Found trades for today ({today}), processing...")
self.process_date(today)
else:
logger.info(f"No trades found for today ({today}) yet, will process later")
# Hauptschleife: Prüfe regelmäßig auf fehlende Tage
logger.info("Starting main loop - checking for missing dates every hour...")
@@ -688,13 +689,23 @@ class AnalyticsWorker:
self.process_missing_dates()
last_check_hour = current_hour
# Stelle sicher, dass gestern verarbeitet wurde
yesterday = (now - datetime.timedelta(days=1)).date()
# Stelle sicher, dass gestern und heute verarbeitet wurden
today = now.date()
yesterday = today - datetime.timedelta(days=1)
existing_dates = self.get_existing_dates('analytics_custom')
if yesterday not in existing_dates:
logger.info(f"Processing yesterday's data: {yesterday}")
self.process_date(yesterday)
# Prüfe heute, ob es Trades gibt
if today not in existing_dates:
query = f"select count(*) from trades where date_trunc('day', timestamp) = '{today}'"
data = self.query_questdb(query)
if data and data.get('dataset') and data['dataset'][0][0] and data['dataset'][0][0] > 0:
logger.info(f"Found trades for today ({today}), processing...")
self.process_date(today)
# Prüfe ob es Mitternacht ist (00:00) - verarbeite dann gestern
if now.hour == 0 and now.minute == 0:
yesterday = (now - datetime.timedelta(days=1)).date()