From 670c5e49b29249f3b96821195d4f8b01a9985197 Mon Sep 17 00:00:00 2001 From: ddamiron <ddamiron@sii.fr> Date: Tue, 2 Jul 2019 14:38:16 +0200 Subject: [PATCH] add progress_ratio tag in log_message --- lib/mongo_session.py | 3 ++- workers/reindexer.py | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/lib/mongo_session.py b/lib/mongo_session.py index 4c27332..2b807c6 100644 --- a/lib/mongo_session.py +++ b/lib/mongo_session.py @@ -44,6 +44,7 @@ class MongoSession: print('body session_id: ', body_object['session_id']) timestamp = datetime.datetime.strptime(body_object["timestamp"], "%Y-%m-%dT%H:%M:%S.%fZ") + float_progress_ratio = float(body_object["progress_ratio"]) self.mongo_data_collection.insert_one({"session_id": body_object["session_id"], "timestamp": timestamp, @@ -52,7 +53,7 @@ class MongoSession: "status": body_object["status"], "uuid_prefix": body_object["uuid_prefix"], "info": body_object["info"], - "progress_ratio": body_object["progress_ratio"], + "progress_ratio": float_progress_ratio, "loglevel": body_object["loglevel"]}) except Exception as exc: print('[ERROR saving log]:', exc) diff --git a/workers/reindexer.py b/workers/reindexer.py index 69d83e3..b609832 100644 --- a/workers/reindexer.py +++ b/workers/reindexer.py @@ -234,7 +234,7 @@ def on_msg_callback(channel, method, properties, body): uuid_prefix='full', info=uuid, loglevel='ERROR', - progress_ratio=None + progress_ratio=1 ) json_body = json.dumps(log_message.__dict__) @@ -307,7 +307,7 @@ def on_msg_callback(channel, method, properties, body): uuid_prefix='full', info=uuid, loglevel='INFO', - progress_ratio=None + progress_ratio=0.4 ) json_body = json.dumps(log_message.__dict__) -- GitLab