diff --git a/.changeset/cancel-failed-run-tasks.md b/.changeset/cancel-failed-run-tasks.md deleted file mode 100644 index cac7539e7..000000000 --- a/.changeset/cancel-failed-run-tasks.md +++ /dev/null @@ -1,5 +0,0 @@ ---- -"@pgflow/core": patch ---- - -Mark unfinished tasks as cancelled when their run fails, prevent late callbacks and stalled recovery from reviving them, and repair active tasks on historical failed runs. diff --git a/.changeset/terminalize-skipped-tasks.md b/.changeset/terminalize-skipped-tasks.md deleted file mode 100644 index f0957d88a..000000000 --- a/.changeset/terminalize-skipped-tasks.md +++ /dev/null @@ -1,9 +0,0 @@ ---- -"@pgflow/core": patch ---- - -Terminalize queued and started task rows when their parent step is skipped: sibling tasks of a step skipped via `whenExhausted: 'skip'`/`'skip-cascade'` (and cascade-skipped steps) now end as `skipped` instead of staying `queued`/`started` forever, and a migration repairs existing rows. - -Tasks are now terminalized before their queue messages are archived, preserving the task-before-queue lock order, and `start_tasks` only returns rows it actually claimed, so workers no longer execute tasks a concurrent skip already marked `skipped`. - -Fixes #638 diff --git a/.changeset/use-effective-step-timeout.md b/.changeset/use-effective-step-timeout.md deleted file mode 100644 index 4bd2bd42a..000000000 --- a/.changeset/use-effective-step-timeout.md +++ /dev/null @@ -1,5 +0,0 @@ ---- -"@pgflow/core": patch ---- - -Requeue stalled tasks using the effective step timeout instead of waiting for the flow timeout. diff --git a/pkgs/cli/CHANGELOG.md b/pkgs/cli/CHANGELOG.md index b27467783..79084796b 100644 --- a/pkgs/cli/CHANGELOG.md +++ b/pkgs/cli/CHANGELOG.md @@ -1,5 +1,14 @@ # pgflow +## 0.15.1 + +### Patch Changes + +- Updated dependencies [7903661] +- Updated dependencies [daadcac] +- Updated dependencies [35d261b] + - @pgflow/core@0.15.1 + ## 0.15.0 ### Minor Changes diff --git a/pkgs/cli/package.json b/pkgs/cli/package.json index 374fcafac..db79b34ae 100644 --- a/pkgs/cli/package.json +++ b/pkgs/cli/package.json @@ -1,6 +1,6 @@ { "name": "pgflow", - "version": "0.15.0", + "version": "0.15.1", "license": "Apache-2.0", "repository": { "type": "git", diff --git a/pkgs/client/CHANGELOG.md b/pkgs/client/CHANGELOG.md index 61957159e..1f505daf3 100644 --- a/pkgs/client/CHANGELOG.md +++ b/pkgs/client/CHANGELOG.md @@ -1,5 +1,15 @@ # @pgflow/client +## 0.15.1 + +### Patch Changes + +- Updated dependencies [7903661] +- Updated dependencies [daadcac] +- Updated dependencies [35d261b] + - @pgflow/core@0.15.1 + - @pgflow/dsl@0.15.1 + ## 0.15.0 ### Minor Changes diff --git a/pkgs/client/package.json b/pkgs/client/package.json index 8b3f236ef..aeb496efd 100644 --- a/pkgs/client/package.json +++ b/pkgs/client/package.json @@ -1,6 +1,6 @@ { "name": "@pgflow/client", - "version": "0.15.0", + "version": "0.15.1", "license": "Apache-2.0", "repository": { "type": "git", diff --git a/pkgs/core/CHANGELOG.md b/pkgs/core/CHANGELOG.md index da75f642b..ea7f6a242 100644 --- a/pkgs/core/CHANGELOG.md +++ b/pkgs/core/CHANGELOG.md @@ -1,5 +1,19 @@ # @pgflow/core +## 0.15.1 + +### Patch Changes + +- 7903661: Mark unfinished tasks as cancelled when their run fails, prevent late callbacks and stalled recovery from reviving them, and repair active tasks on historical failed runs. +- daadcac: Terminalize queued and started task rows when their parent step is skipped: sibling tasks of a step skipped via `whenExhausted: 'skip'`/`'skip-cascade'` (and cascade-skipped steps) now end as `skipped` instead of staying `queued`/`started` forever, and a migration repairs existing rows. + + Tasks are now terminalized before their queue messages are archived, preserving the task-before-queue lock order, and `start_tasks` only returns rows it actually claimed, so workers no longer execute tasks a concurrent skip already marked `skipped`. + + Fixes #638 + +- 35d261b: Requeue stalled tasks using the effective step timeout instead of waiting for the flow timeout. + - @pgflow/dsl@0.15.1 + ## 0.15.0 ### Minor Changes diff --git a/pkgs/core/package.json b/pkgs/core/package.json index b0ca4d68f..35a8c0dba 100644 --- a/pkgs/core/package.json +++ b/pkgs/core/package.json @@ -1,6 +1,6 @@ { "name": "@pgflow/core", - "version": "0.15.0", + "version": "0.15.1", "license": "Apache-2.0", "repository": { "type": "git", diff --git a/pkgs/dsl/CHANGELOG.md b/pkgs/dsl/CHANGELOG.md index 16ca841b6..22dbe23d9 100644 --- a/pkgs/dsl/CHANGELOG.md +++ b/pkgs/dsl/CHANGELOG.md @@ -1,5 +1,7 @@ # @pgflow/dsl +## 0.15.1 + ## 0.15.0 ### Minor Changes diff --git a/pkgs/dsl/package.json b/pkgs/dsl/package.json index ed32903cc..9259ddf38 100644 --- a/pkgs/dsl/package.json +++ b/pkgs/dsl/package.json @@ -1,6 +1,6 @@ { "name": "@pgflow/dsl", - "version": "0.15.0", + "version": "0.15.1", "license": "Apache-2.0", "repository": { "type": "git", diff --git a/pkgs/edge-worker/CHANGELOG.md b/pkgs/edge-worker/CHANGELOG.md index 26b1a1baf..c9adf5bfa 100644 --- a/pkgs/edge-worker/CHANGELOG.md +++ b/pkgs/edge-worker/CHANGELOG.md @@ -1,5 +1,15 @@ # @pgflow/edge-worker +## 0.15.1 + +### Patch Changes + +- Updated dependencies [7903661] +- Updated dependencies [daadcac] +- Updated dependencies [35d261b] + - @pgflow/core@0.15.1 + - @pgflow/dsl@0.15.1 + ## 0.15.0 ### Minor Changes diff --git a/pkgs/edge-worker/jsr.json b/pkgs/edge-worker/jsr.json index b5755c05a..1c72c9d46 100644 --- a/pkgs/edge-worker/jsr.json +++ b/pkgs/edge-worker/jsr.json @@ -1,6 +1,6 @@ { "name": "@pgflow/edge-worker", - "version": "0.15.0", + "version": "0.15.1", "license": "Apache-2.0", "exports": { ".": "./src/index.ts", @@ -10,8 +10,8 @@ "@henrygd/queue": "jsr:@henrygd/queue@^1.0.7", "@std/crypto": "jsr:@std/crypto@^1.0.5", "postgres": "jsr:@oscar6echo/postgres@3.4.5-d", - "@pgflow/core": "npm:@pgflow/core@0.15.0", - "@pgflow/dsl": "npm:@pgflow/dsl@0.15.0" + "@pgflow/core": "npm:@pgflow/core@0.15.1", + "@pgflow/dsl": "npm:@pgflow/dsl@0.15.1" }, "publish": { "include": [ diff --git a/pkgs/edge-worker/package.json b/pkgs/edge-worker/package.json index cbede759b..064deabad 100644 --- a/pkgs/edge-worker/package.json +++ b/pkgs/edge-worker/package.json @@ -1,6 +1,6 @@ { "name": "@pgflow/edge-worker", - "version": "0.15.0", + "version": "0.15.1", "license": "Apache-2.0", "repository": { "type": "git",