diff options
Diffstat (limited to 'store.py')
-rw-r--r-- | store.py | 6 |
1 files changed, 4 insertions, 2 deletions
@@ -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)) |