mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-05-08 02:49:17 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: improved assign, reassign, and requeue (#702)

Browse Source 
* fix: improved queries

* fix: 1s timeout

* fix: indexes

* fix: increase timeout to 4s

* fix: migration

* merge in db changes

* chore: squash migrations

* chore: re-hash

* chore: remove comment

* chore: rm unused query

* fix: state

* fix: check valid workers before commit

* fix: query

* chore: gen
This commit is contained in:
Gabe Ruttner
2024-07-10 09:45:08 -07:00
committed by GitHub
parent 560ac1ba5c
commit 1e20bf946a
14 changed files with 356 additions and 255 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sql/schema/schema.sql
+13 -1
View File
@@ -846,6 +846,9 @@ CREATE UNIQUE INDEX "Step_jobId_readableId_key" ON "Step"("jobId" ASC, "readable
-- CreateIndex
CREATE UNIQUE INDEX "StepRateLimit_stepId_rateLimitKey_key" ON "StepRateLimit"("stepId" ASC, "rateLimitKey" ASC);
-- CreateIndex
CREATE INDEX "StepRun_createdAt_idx" ON "StepRun"("createdAt" ASC);
-- CreateIndex
CREATE UNIQUE INDEX "StepRun_id_key" ON "StepRun"("id" ASC);
@@ -858,6 +861,12 @@ CREATE INDEX "StepRun_jobRunId_status_idx" ON "StepRun"("jobRunId" ASC, "status"
-- CreateIndex
CREATE INDEX "StepRun_jobRunId_tenantId_order_idx" ON "StepRun"("jobRunId" ASC, "tenantId" ASC, "order" ASC);
-- CreateIndex
CREATE INDEX "StepRun_requeueAfter_idx" ON "StepRun"("requeueAfter" ASC);
-- CreateIndex
CREATE INDEX "StepRun_status_idx" ON "StepRun"("status" ASC);
-- CreateIndex
CREATE INDEX "StepRun_status_timeoutAt_tickerId_idx" ON "StepRun"("status" ASC, "timeoutAt" ASC, "tickerId" ASC);
@@ -865,7 +874,10 @@ CREATE INDEX "StepRun_status_timeoutAt_tickerId_idx" ON "StepRun"("status" ASC,
CREATE INDEX "StepRun_stepId_idx" ON "StepRun"("stepId" ASC);
-- CreateIndex
CREATE INDEX "StepRun_tenantId_status_requeueAfter_createdAt_idx" ON "StepRun"("tenantId" ASC, "status" ASC, "requeueAfter" ASC, "createdAt" ASC);
CREATE INDEX "StepRun_tenantId_idx" ON "StepRun"("tenantId" ASC);
-- CreateIndex
CREATE INDEX "StepRun_timeoutAt_idx" ON "StepRun"("timeoutAt" ASC);
-- CreateIndex
CREATE UNIQUE INDEX "StepRunEvent_id_key" ON "StepRunEvent"("id" ASC);