From 23e54d57da6f1f4d04266558b108c8e1f37902c8 Mon Sep 17 00:00:00 2001 From: Andres V Date: Thu, 6 Mar 2025 17:27:31 -0800 Subject: [PATCH] Seriously, we shoould drop postgres support --- internal/app/subsystems/aio/store/postgres/postgres.go | 2 +- internal/app/subsystems/aio/store/test/cases.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/app/subsystems/aio/store/postgres/postgres.go b/internal/app/subsystems/aio/store/postgres/postgres.go index 56ce062c..57d4513f 100644 --- a/internal/app/subsystems/aio/store/postgres/postgres.go +++ b/internal/app/subsystems/aio/store/postgres/postgres.go @@ -362,7 +362,7 @@ const ( SET state = 8, completed_on = $1 -- State = 8 -> Completed WHERE - root_promise_id = $2 AND state in (1, 2) -- State in (Init, Enqueued)` + root_promise_id = $2 AND state in (1, 2, 4) -- State in (Init, Enqueued, Claimed)` TASK_HEARTBEAT_STATEMENT = ` UPDATE diff --git a/internal/app/subsystems/aio/store/test/cases.go b/internal/app/subsystems/aio/store/test/cases.go index c561c559..af550e31 100644 --- a/internal/app/subsystems/aio/store/test/cases.go +++ b/internal/app/subsystems/aio/store/test/cases.go @@ -4183,7 +4183,7 @@ var TestCases = []*testCase{ { Id: "foo.1", ProcessId: util.ToPointer("pid"), - State: task.Completed, // Task should remain in Claimed state + State: task.Completed, RootPromiseId: "root", Recv: []byte("foo"), Mesg: []byte(`{"type":"resume","root":"root","leaf":"foo"}`),