Skip to content

Commit 36191f6

Browse files
committed
fix(webapp): store geo region in clickhouse to hide compute backing from query
1 parent 1b7e8ec commit 36191f6

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,8 @@ import pLimit from "p-limit";
3939
import { detectBadJsonStrings } from "~/utils/detectBadJsonStrings";
4040
import { calculateErrorFingerprint } from "~/utils/errorFingerprinting";
4141
import { baseWorkerQueue } from "~/runEngine/concerns/workerQueueSplit.server";
42+
import { regionForBacking } from "~/runEngine/concerns/computeMigration.server";
43+
import { computeBackingMap } from "~/v3/computeBackingMap.server";
4244
import {
4345
isClickHouseJsonParseError,
4446
parseRowNumberFromError,
@@ -1122,7 +1124,7 @@ export class RunsReplicationService {
11221124
event === "delete" ? 1 : 0, // _is_deleted
11231125
run.concurrencyKey ?? "", // concurrency_key
11241126
run.bulkActionGroupIds ?? [], // bulk_action_group_ids
1125-
baseWorkerQueue(run.masterQueue ?? ""), // worker_queue (region; strip any split suffix like `:scheduled`)
1127+
regionForBacking(baseWorkerQueue(run.masterQueue ?? ""), computeBackingMap), // worker_queue (geo region; strip `:scheduled` and hide the compute backing - customers query this column)
11261128
run.maxDurationInSeconds ?? null, // max_duration_in_seconds
11271129
annotations?.triggerSource ?? "", // trigger_source
11281130
annotations?.rootTriggerSource ?? "", // root_trigger_source

0 commit comments

Comments
 (0)