Skip to content

Commit

Permalink
Merge pull request #992 from TeachMeTW/Renamed_User_Stats
Browse files Browse the repository at this point in the history
Renamed Get_Store_Range to be compatible for future additions
  • Loading branch information
shankari authored Nov 5, 2024
2 parents c8e8080 + 2a32742 commit ab3997e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions emission/pipeline/intake_stage.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down

0 comments on commit ab3997e

Please sign in to comment.