Discussed with Jack, approved with this change to clarify pipeline stage

e-mission · Nov 5, 2024 · 2a32742 · 2a32742
1 parent c8e8080
commit 2a32742
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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):