X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=store.py;h=0c018e017b062aed66fd558cafaa1ef10ed722d6;hb=9fe90554ff1c8c7aea9e1e1e210419a845579edd;hp=467dd4b40cfd9ef05a9a0974c88e40f1560d8c1b;hpb=c8df27385e02b22d36b240fe29532e97dbba1f43;p=perso%2FImmae%2FProjets%2FCryptomonnaies%2FCryptoportfolio%2FTrader.git

diff --git a/store.py b/store.py
index 467dd4b..0c018e0 100644
--- a/store.py
+++ b/store.py
@@ -211,6 +211,7 @@ class ReportStore:
                 "body": body,
                 "headers": headers,
                 "status": response.status_code,
+                "duration": response.elapsed.total_seconds(),
                 "response": None,
                 "response_same_as": self.last_http["date"]
                 })
@@ -222,6 +223,7 @@ class ReportStore:
                 "body": body,
                 "headers": headers,
                 "status": response.status_code,
+                "duration": response.elapsed.total_seconds(),
                 "response": response.text,
                 "response_same_as": None,
                 })
@@ -409,6 +411,7 @@ class Portfolio:
     last_date = LockedVar(None)
     report = LockedVar(ReportStore(None, no_http_dup=True))
     worker = None
+    worker_tag = ""
     worker_started = False
     worker_notify = None
     callback = None
@@ -426,6 +429,7 @@ class Portfolio:
         cls.liquidities.start_lock()
         cls.report.start_lock()
 
+        cls.worker_tag = "[Worker] "
         cls.worker_started = True
         cls.worker.start()
 
@@ -445,7 +449,7 @@ class Portfolio:
             cls.worker_notify.wait()
             if cls.worker_started:
                 cls.worker_notify.clear()
-                cls.report.print_log("Fetching cryptoportfolio")
+                cls.report.print_log("[Worker] Fetching cryptoportfolio")
                 cls.get_cryptoportfolio(refetch=True)
                 cls.callback.set()
                 time.sleep(poll)
@@ -488,7 +492,7 @@ class Portfolio:
             cls.report.log_http_request(r.request.method,
                     r.request.url, r.request.body, r.request.headers, r)
         except Exception as e:
-            cls.report.log_error("get_cryptoportfolio", exception=e)
+            cls.report.log_error("{}get_cryptoportfolio".format(cls.worker_tag), exception=e)
             return
         try:
             cls.data.set(r.json(parse_int=D, parse_float=D))