Skip to content
Open
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.

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.

9 changes: 9 additions & 0 deletions pkgs/cli/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -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
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
10 changes: 10 additions & 0 deletions pkgs/client/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -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
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
14 changes: 14 additions & 0 deletions pkgs/core/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -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
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
10 changes: 10 additions & 0 deletions pkgs/edge-worker/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -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
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