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):