starred/orca
1
0
Fork 0
mirror of https://github.com/stablyai/orca.git synced 2026-10-23 00:03:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(orchestration): guard skewed inbox indexes

Browse Source
This commit is contained in:
Jinwoo-H
2026-08-14 16:35:55 -04:00
committed by Jinwoo-H
parent c68cfdb18f
commit faf0e67c86
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/runtime/orchestration/db.ts
+13 -3
View File
@@ -1429,12 +1429,22 @@ export class OrchestrationDb {
}
private createUndeliveredInboxIndexIfPossible(): void {
if (!this.hasColumn('messages', 'delivered_at')) {
const hasDeliveredAt = this.hasColumn('messages', 'delivered_at')
if (hasDeliveredAt) {
this.db.exec(`
CREATE INDEX IF NOT EXISTS idx_messages_undelivered_inbox
ON messages(to_handle, read, delivered_at, sequence)
`)
}
if (
!hasDeliveredAt ||
!this.hasColumn('messages', 'run_id') ||
!this.hasColumn('messages', 'delivery_contract')
) {
return
}
this.db.exec(`
CREATE INDEX IF NOT EXISTS idx_messages_undelivered_inbox
ON messages(to_handle, read, delivered_at, sequence);
CREATE INDEX IF NOT EXISTS idx_messages_undelivered_direct_run
ON messages(run_id, to_handle, sequence)
WHERE read = 0 AND delivered_at IS NULL