Fixing bug in SQL

OHDSI · Dec 22, 2023 · 8cb3bbe · 8cb3bbe
1 parent 1f4b291
commit 8cb3bbe
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/cdm_processing/cdm_processor.py b/cdm_processing/cdm_processor.py
@@ -179,7 +179,8 @@ def _create_sequence_tables(self,
  sql = "SELECT tokens.*, " \
  f"{part1}" \
  " ROW_NUMBER() OVER " \
- " (PARTITION BY observation_period_id ORDER BY visit_concept_orders, sort_order) - 1 AS orders " \
+ " (PARTITION BY tokens.observation_period_id ORDER BY visit_concept_orders, sort_order) - 1 " \
+ " AS orders " \
  "FROM (" \
  " SELECT * FROM interval_tokens " \
  " UNION ALL " \
@@ -190,7 +191,7 @@ def _create_sequence_tables(self,
  " SELECT * FROM end_tokens" \
  ") tokens " \
  f"{part2}" \
- "ORDER BY observation_period_id, visit_concept_orders, sort_order"
+ "ORDER BY tokens.observation_period_id, visit_concept_orders, sort_order"
  union_tokens = con.execute(sql).arrow()
  con.execute("DROP TABLE visits")
  con.execute("DROP TABLE interval_tokens")