Skip to content

Commit

Permalink
Merge pull request #922 from openedx/bmtcril/clickhouse_24_8
Browse files Browse the repository at this point in the history
feat: Upgrade ClickHouse to 24.8
  • Loading branch information
Cristhian Garcia authored Aug 26, 2024
2 parents 008fc74 + 1f64b89 commit 393f588
Show file tree
Hide file tree
Showing 3 changed files with 16 additions and 10 deletions.
2 changes: 1 addition & 1 deletion tutoraspects/plugin.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
("RUN_RALPH", True),
("RUN_SUPERSET", True),
("DOCKER_IMAGE_ASPECTS", "edunext/aspects:{{ ASPECTS_VERSION }}"),
("DOCKER_IMAGE_CLICKHOUSE", "clickhouse/clickhouse-server:24.3"),
("DOCKER_IMAGE_CLICKHOUSE", "clickhouse/clickhouse-server:24.8"),
("DOCKER_IMAGE_RALPH", "fundocker/ralph:4.1.0"),
("DOCKER_IMAGE_SUPERSET", "edunext/aspects-superset:{{ ASPECTS_VERSION }}"),
("DOCKER_IMAGE_VECTOR", "timberio/vector:0.30.0-alpine"),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,32 +17,31 @@


def drop_objects():
# We include these drop statements here because "CREATE OR REPLACE DICTIONARY"
# currently throws a file rename error and you can't drop a dictionary with a
# table referring to it.
op.execute(
f"""
DROP TABLE IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.most_recent_course_blocks
DROP TABLE IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_block_names
{on_cluster}
"""
)

op.execute(
f"""
DROP VIEW IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.most_recent_course_blocks_mv
DROP DICTIONARY IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_block_names_dict
{on_cluster}
"""
)

# We include these drop statements here because "CREATE OR REPLACE DICTIONARY"
# currently throws a file rename error and you can't drop a dictionary with a
# table referring to it.
op.execute(
f"""
DROP TABLE IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_block_names
DROP TABLE IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.most_recent_course_blocks
{on_cluster}
"""
)

op.execute(
f"""
DROP DICTIONARY IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_block_names_dict
DROP VIEW IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.most_recent_course_blocks_mv
{on_cluster}
"""
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,13 @@ def drop_objects():
"""
)

op.execute(
f"""
DROP DICTIONARY IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_block_names
{on_cluster}
"""
)

op.execute(
f"""
DROP TABLE IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.most_recent_course_blocks
Expand Down

0 comments on commit 393f588

Please sign in to comment.