diff --git a/main.py b/main.py index e0327a4d6c7186d5e29b38cd21087b81d4c87b2d..a12a90638e00555c3e3b8b2e5e30a440d3dce2b3 100644 --- a/main.py +++ b/main.py @@ -187,7 +187,7 @@ def delete_dataset_from_dest_index(the_rabbit, the_cfg, the_uuid): uuid_prefix='meta', info='no info', loglevel='INFO', - progress_ratio=0.2 + progress_ratio=0.1 ) the_rabbit.publish_log(log_message=log_message.__dict__) # ------------------------------------------------------------ diff --git a/workers/reindexer.py b/workers/reindexer.py index 90f3ccb78b114517164e997ffff5a2b1cf6a5ba2..75fb6aae51dc24fa896af1441fda5b7cc336d678 100644 --- a/workers/reindexer.py +++ b/workers/reindexer.py @@ -42,7 +42,7 @@ def create_sampling_task(cfg, channel, uuid): uuid_prefix='full', info=uuid, loglevel='INFO', - progress_ratio=0.4 + progress_ratio=0.8 ) json_body = json.dumps(log_message.__dict__) @@ -207,7 +207,7 @@ def on_msg_callback(channel, method, properties, body): uuid_prefix='full', info=uuid, loglevel='INFO', - progress_ratio=0.8 + progress_ratio=0.2 ) json_body = json.dumps(log_message.__dict__) @@ -273,7 +273,7 @@ def on_msg_callback(channel, method, properties, body): uuid_prefix='meta', info=uuid, loglevel='INFO', - progress_ratio=0.9 + progress_ratio=0.6 ) json_body = json.dumps(log_message.__dict__) @@ -375,7 +375,7 @@ def on_msg_callback(channel, method, properties, body): uuid_prefix='full', info=uuid, loglevel='INFO', - progress_ratio=1 + progress_ratio=0.9 ) json_body = json.dumps(log_message.__dict__)