aboutsummaryrefslogtreecommitdiff
path: root/store.py
diff options
context:
space:
mode:
Diffstat (limited to 'store.py')
-rw-r--r--store.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/store.py b/store.py
index 467dd4b..45a5233 100644
--- a/store.py
+++ b/store.py
@@ -409,6 +409,7 @@ class Portfolio:
409 last_date = LockedVar(None) 409 last_date = LockedVar(None)
410 report = LockedVar(ReportStore(None, no_http_dup=True)) 410 report = LockedVar(ReportStore(None, no_http_dup=True))
411 worker = None 411 worker = None
412 worker_tag = ""
412 worker_started = False 413 worker_started = False
413 worker_notify = None 414 worker_notify = None
414 callback = None 415 callback = None
@@ -426,6 +427,7 @@ class Portfolio:
426 cls.liquidities.start_lock() 427 cls.liquidities.start_lock()
427 cls.report.start_lock() 428 cls.report.start_lock()
428 429
430 cls.worker_tag = "[Worker] "
429 cls.worker_started = True 431 cls.worker_started = True
430 cls.worker.start() 432 cls.worker.start()
431 433
@@ -445,7 +447,7 @@ class Portfolio:
445 cls.worker_notify.wait() 447 cls.worker_notify.wait()
446 if cls.worker_started: 448 if cls.worker_started:
447 cls.worker_notify.clear() 449 cls.worker_notify.clear()
448 cls.report.print_log("Fetching cryptoportfolio") 450 cls.report.print_log("[Worker] Fetching cryptoportfolio")
449 cls.get_cryptoportfolio(refetch=True) 451 cls.get_cryptoportfolio(refetch=True)
450 cls.callback.set() 452 cls.callback.set()
451 time.sleep(poll) 453 time.sleep(poll)
@@ -488,7 +490,7 @@ class Portfolio:
488 cls.report.log_http_request(r.request.method, 490 cls.report.log_http_request(r.request.method,
489 r.request.url, r.request.body, r.request.headers, r) 491 r.request.url, r.request.body, r.request.headers, r)
490 except Exception as e: 492 except Exception as e:
491 cls.report.log_error("get_cryptoportfolio", exception=e) 493 cls.report.log_error("{}get_cryptoportfolio".format(cls.worker_tag), exception=e)
492 return 494 return
493 try: 495 try:
494 cls.data.set(r.json(parse_int=D, parse_float=D)) 496 cls.data.set(r.json(parse_int=D, parse_float=D))