Change the scheme to have rows ordered by updated_at

This commit is contained in:
Mikhail f. Shiryaev 2022-12-23 12:05:05 +01:00
parent 7d7efcbccd
commit e9829b0d46
No known key found for this signature in database
GPG Key ID: 4B02ED204C7D93F4

View File

@ -200,9 +200,8 @@ clickhouse_client = ClickHouseHelper()
def send_event_workflow_job(workflow_job: WorkflowJob) -> None:
# SHOW CREATE TABLE default.workflow_jobs
# CREATE TABLE default.workflow_jobs
# UUID 'c035192a-8ccd-47a6-9db0-f28a9eee2fde'
# # SHOW CREATE TABLE default.workflow_jobs
# CREATE TABLE default.workflow_jobs UUID 'c0351924-8ccd-47a6-9db0-e28a9eee2fdf'
# (
# `id` UInt64,
# `run_id` UInt64,
@ -226,13 +225,12 @@ def send_event_workflow_job(workflow_job: WorkflowJob) -> None:
# `runner_name` String,
# `runner_group_id` UInt64,
# `runner_group_name` LowCardinality(String),
# `repository` LowCardinality(String)
# )
# ENGINE = ReplicatedMergeTree(
# '/clickhouse/tables/c035192a-8ccd-47a6-9db0-f28a9eee2fde/{shard}', '{replica}'
# `repository` LowCardinality(String),
# `updated_at` DateTime DEFAULT now()
# )
# ENGINE = ReplicatedMergeTree('/clickhouse/tables/c0351924-8ccd-47a6-9db0-e28a9eee2fdf/{shard}', '{replica}')
# PARTITION BY toStartOfMonth(started_at)
# ORDER BY (id, started_at)
# ORDER BY (id, updated_at)
# SETTINGS index_granularity = 8192
global clickhouse_client
kwargs = {