jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Api v1.15.0 (#1637)

Browse source 
* fix(chalice): fixed path-analysis's density support
This commit is contained in:
Kraiem Taha Yassine 2023-11-09 18:40:44 +01:00 • committed by GitHub
parent deb8f551c1
commit 1d5e07080e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
api/chalicelib/core/product_analytics.py
View file

@ -349,7 +349,8 @@ def path_analysis(project_id: int, data: schemas.CardPathAnalysis):
sessions_count,
avg_time_from_previous
FROM n1)"""]
for i in range(2, data.density):
for i in range(2, data.density + 1):
steps_query.append(f"""n{i} AS (SELECT *
FROM (SELECT re.event_number_in_session,
re.event_type,
@ -388,7 +389,7 @@ WITH sub_sessions AS (SELECT session_id {sub_sessions_extra_projection}
row_number() OVER (PARTITION BY session_id ORDER BY timestamp {path_direction}) AS event_number_in_session
FROM sub_events
ORDER BY session_id) AS full_ranked_events
WHERE event_number_in_session < %(density)s),
WHERE event_number_in_session <= %(density)s),
start_points AS (SELECT session_id
FROM {start_points_from}
WHERE {" AND ".join(start_points_conditions)}),

4
ee/api/chalicelib/core/product_analytics.py
View file

@ -382,7 +382,7 @@ def path_analysis(project_id: int, data: schemas.CardPathAnalysis):
sessions_count,
avg_time_from_previous
FROM n1"""]
for i in range(2, data.density):
for i in range(2, data.density + 1):
steps_query.append(f"""n{i} AS (SELECT *
FROM (SELECT re.event_number_in_session AS event_number_in_session,
re.event_type AS event_type,
@ -428,7 +428,7 @@ WITH {initial_event_cte}
FROM {main_table}
WHERE {" AND ".join(ch_sub_query)}
) AS full_ranked_events
WHERE event_number_in_session < 4)
WHERE event_number_in_session <= %(density)s)
SELECT *
FROM pre_ranked_events;"""
ch.execute(query=ch_query1, params=params)