Skip to content

Commit 90a6034

Browse files
committed
added back in max duration in seconds
1 parent 03c564a commit 90a6034

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -918,6 +918,7 @@ export class RunsReplicationService {
918918
run.concurrencyKey ?? "", // concurrency_key
919919
run.bulkActionGroupIds ?? [], // bulk_action_group_ids
920920
run.masterQueue ?? "", // worker_queue
921+
run.maxDurationInSeconds ?? 0, // max_duration_in_seconds
921922
_version.toString(), // _version
922923
event === "delete" ? 1 : 0, // _is_deleted
923924
];

internal-packages/clickhouse/src/taskRuns.ts

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,7 @@ export const TASK_RUN_COLUMNS = [
121121
"concurrency_key",
122122
"bulk_action_group_ids",
123123
"worker_queue",
124+
"max_duration_in_seconds",
124125
"_version",
125126
"_is_deleted",
126127
] as const;
@@ -227,7 +228,10 @@ export function insertRawTaskRunPayloads(ch: ClickhouseWriter, settings?: ClickH
227228
});
228229
}
229230

230-
export function insertRawTaskRunPayloadsUnsafe(ch: ClickhouseWriter, settings?: ClickHouseSettings) {
231+
export function insertRawTaskRunPayloadsUnsafe(
232+
ch: ClickhouseWriter,
233+
settings?: ClickHouseSettings
234+
) {
231235
return ch.insertUnsafe({
232236
name: "insertRawTaskRunPayloadsUnsafe",
233237
table: "trigger_dev.raw_task_runs_payload_v1",

0 commit comments

Comments
 (0)