diff --git a/lib/mongo_session.py b/lib/mongo_session.py index 4c273323693839937e8f12553652736cfb5179cf..2b807c6314b0e036dbdf9563115fb90cec9b2482 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 69d83e3e117d84691b91765dd4a056819a1d0925..b60983292d00411a5f071d3230b9ca33d7c56647 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__)