Skip to content

Commit 5fee4b9

Browse files
committed
Added max_duration_in_seconds to ClickHouse
1 parent 109e8c6 commit 5fee4b9

File tree

3 files changed

+12
-0
lines changed

3 files changed

+12
-0
lines changed

apps/webapp/app/services/runsReplicationService.server.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -831,6 +831,7 @@ export class RunsReplicationService {
831831
concurrency_key: run.concurrencyKey ?? "",
832832
bulk_action_group_ids: run.bulkActionGroupIds ?? [],
833833
worker_queue: run.masterQueue,
834+
max_duration_in_seconds: run.maxDurationInSeconds ?? undefined,
834835
_version: _version.toString(),
835836
_is_deleted: event === "delete" ? 1 : 0,
836837
};
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
-- +goose Up
2+
/*
3+
Add max_duration_in_seconds column.
4+
*/
5+
ALTER TABLE trigger_dev.task_runs_v2
6+
ADD COLUMN max_duration_in_seconds Nullable (UInt32) DEFAULT NULL;
7+
8+
-- +goose Down
9+
ALTER TABLE trigger_dev.task_runs_v2
10+
DROP COLUMN max_duration_in_seconds;

internal-packages/clickhouse/src/taskRuns.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@ export const TaskRunV2 = z.object({
4545
concurrency_key: z.string().default(""),
4646
bulk_action_group_ids: z.array(z.string()).default([]),
4747
worker_queue: z.string().default(""),
48+
max_duration_in_seconds: z.number().int().nullish(),
4849
_version: z.string(),
4950
_is_deleted: z.number().int().default(0),
5051
});

0 commit comments

Comments
 (0)