"body": body,
"headers": headers,
"status": response.status_code,
+ "duration": response.elapsed.total_seconds(),
"response": None,
"response_same_as": self.last_http["date"]
})
"body": body,
"headers": headers,
"status": response.status_code,
+ "duration": response.elapsed.total_seconds(),
"response": response.text,
"response_same_as": None,
})
last_date = LockedVar(None)
report = LockedVar(ReportStore(None, no_http_dup=True))
worker = None
+ worker_tag = ""
worker_started = False
worker_notify = None
callback = None
cls.liquidities.start_lock()
cls.report.start_lock()
+ cls.worker_tag = "[Worker] "
cls.worker_started = True
cls.worker.start()
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)
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))