Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 0 additions & 5 deletions .changeset/cancel-failed-run-tasks.md

This file was deleted.

5 changes: 0 additions & 5 deletions .changeset/remove-windows-breaking-postinstall.md

This file was deleted.

5 changes: 0 additions & 5 deletions .changeset/start-tasks-visibility.md

This file was deleted.

9 changes: 0 additions & 9 deletions .changeset/terminalize-skipped-tasks.md

This file was deleted.

5 changes: 0 additions & 5 deletions .changeset/use-effective-step-timeout.md

This file was deleted.

11 changes: 11 additions & 0 deletions pkgs/cli/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,16 @@
# pgflow

## 0.15.1

### Patch Changes

- 4ac87c9: Remove the postinstall `chmod` script that broke `npm install pgflow` on Windows; npm sets the executable bit for `bin` files automatically.
- Updated dependencies [7903661]
- Updated dependencies [078aa1e]
- Updated dependencies [daadcac]
- Updated dependencies [35d261b]
- @pgflow/core@0.15.1

## 0.15.0

### Minor Changes
Expand Down
2 changes: 1 addition & 1 deletion pkgs/cli/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "pgflow",
"version": "0.15.0",
"version": "0.15.1",
"license": "Apache-2.0",
"repository": {
"type": "git",
Expand Down
11 changes: 11 additions & 0 deletions pkgs/client/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,16 @@
# @pgflow/client

## 0.15.1

### Patch Changes

- Updated dependencies [7903661]
- Updated dependencies [078aa1e]
- Updated dependencies [daadcac]
- Updated dependencies [35d261b]
- @pgflow/core@0.15.1
- @pgflow/dsl@0.15.1

## 0.15.0

### Minor Changes
Expand Down
2 changes: 1 addition & 1 deletion pkgs/client/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@pgflow/client",
"version": "0.15.0",
"version": "0.15.1",
"license": "Apache-2.0",
"repository": {
"type": "git",
Expand Down
15 changes: 15 additions & 0 deletions pkgs/core/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,20 @@
# @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.
- 078aa1e: Make `start_tasks()` apply the PGMQ visibility extension before it returns claimed tasks. The visibility update is now structurally required (referenced CTE instead of an unreferenced `SELECT` CTE PostgreSQL may skip), so a claimed task keeps the effective timeout (`coalesce(step timeout, flow timeout) + 2`) instead of only the initial read visibility, and a visibility-update failure rolls back the whole claim.
- 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
Expand Down
2 changes: 1 addition & 1 deletion pkgs/core/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@pgflow/core",
"version": "0.15.0",
"version": "0.15.1",
"license": "Apache-2.0",
"repository": {
"type": "git",
Expand Down
2 changes: 2 additions & 0 deletions pkgs/dsl/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
# @pgflow/dsl

## 0.15.1

## 0.15.0

### Minor Changes
Expand Down
2 changes: 1 addition & 1 deletion pkgs/dsl/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@pgflow/dsl",
"version": "0.15.0",
"version": "0.15.1",
"license": "Apache-2.0",
"repository": {
"type": "git",
Expand Down
11 changes: 11 additions & 0 deletions pkgs/edge-worker/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,16 @@
# @pgflow/edge-worker

## 0.15.1

### Patch Changes

- Updated dependencies [7903661]
- Updated dependencies [078aa1e]
- Updated dependencies [daadcac]
- Updated dependencies [35d261b]
- @pgflow/core@0.15.1
- @pgflow/dsl@0.15.1

## 0.15.0

### Minor Changes
Expand Down
6 changes: 3 additions & 3 deletions pkgs/edge-worker/jsr.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@pgflow/edge-worker",
"version": "0.15.0",
"version": "0.15.1",
"license": "Apache-2.0",
"exports": {
".": "./src/index.ts",
Expand All @@ -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": [
Expand Down
2 changes: 1 addition & 1 deletion pkgs/edge-worker/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@pgflow/edge-worker",
"version": "0.15.0",
"version": "0.15.1",
"license": "Apache-2.0",
"repository": {
"type": "git",
Expand Down
Loading