Workflowy z pgflow

pgflow (Apache-2.0) definiuje workflowy w TypeScript jako graf kroków z zależnościami, ponowieniami i fan-outem; stan trzyma w Postgresie (schemat pgflow), a zadania rozdziela przez kolejki pgmq.

Instalacja

Integracje → Workflowy (pgflow) → Zainstaluj wgrywa migracje z pakietu @pgflow/core (zapisane w historii migracji projektu, zgodnie z supabase db push), a następnie:

• wyłącza telemetrię pgflow (anonimowe dzienne statystyki do telemetry.pgflow.dev — możesz ją włączyć w panelu),
• ustawia sekret Edge Functions EDGE_WORKER_DB_URL,
• zastępuje nadzór workerów pgflow (zakłada adresy *.supabase.co) zadaniem pg_cron, które co 30 s budzi workery pod https://<ref>.host.ulewicz.space/functions/v1/<nazwa>.

Worker

Utwórz Edge Function z szablonu Worker pgflow i wywołaj ją raz — przy starcie worker kompiluje flow w bazie:

import { EdgeWorker } from "jsr:@pgflow/edge-worker@0.17.2";
import { Flow } from "npm:@pgflow/dsl@0.17.2";

const Powitanie = new Flow<{ imie: string }>({ slug: "powitanie" })
  .step({ slug: "tekst" }, (input) => "Cześć, " + input.imie + "!");

EdgeWorker.start(Powitanie);

Uruchamianie

select * from pgflow.start_flow('powitanie', '{"imie": "Ala"}'::jsonb);

Panel pokazuje flows, przebiegi (filtr po statusie), kroki z czasami, liczbą prób, błędami i wynikami.