We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5ddabad commit 443f63bCopy full SHA for 443f63b
apps/webapp/app/services/runsReplicationService.server.ts
@@ -216,6 +216,10 @@ export class RunsReplicationService {
216
callback: this.#flushBatch.bind(this),
217
// Key-based deduplication to reduce duplicates sent to ClickHouse
218
getKey: (item) => {
219
+ if (!item?.run?.id) {
220
+ this.logger.warn("Skipping replication event with null run", { event: item });
221
+ return null;
222
+ }
223
return `${item.event}_${item.run.id}`;
224
},
225
// Keep the run with the higher version (latest)
0 commit comments