From 2a327421d20b4dd5e3989cdd042df9e645bd1707 Mon Sep 17 00:00:00 2001 From: TeachMeTW Date: Tue, 5 Nov 2024 14:35:36 -0800 Subject: [PATCH] Discussed with Jack, approved with this change to clarify pipeline stage --- emission/pipeline/intake_stage.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/emission/pipeline/intake_stage.py b/emission/pipeline/intake_stage.py index b681f93d5..424d85e32 100644 --- a/emission/pipeline/intake_stage.py +++ b/emission/pipeline/intake_stage.py @@ -199,11 +199,11 @@ def run_intake_pipeline_for_user(uuid, skip_if_no_new_data): time.time(), crt.elapsed) with ect.Timer() as gsr: - logging.info("*" * 10 + "UUID %s: generating store and range " % uuid + "*" * 10) - print(str(arrow.now()) + "*" * 10 + "UUID %s: generating store and range " % uuid + "*" * 10) + logging.info("*" * 10 + "UUID %s: storing user stats " % uuid + "*" * 10) + print(str(arrow.now()) + "*" * 10 + "UUID %s: storing user stats " % uuid + "*" * 10) _get_and_store_range(uuid, "analysis/composite_trip") - esds.store_pipeline_time(uuid, 'GENERATE_STORE_AND_RANGE', + esds.store_pipeline_time(uuid, 'STORE_USER_STATS', time.time(), gsr.elapsed) def _get_and_store_range(user_id, trip_key):