Add durable workflow examples (RFC-0022)#94
Open
sanketsudake wants to merge 3 commits into
Open
Conversation
Three real business processes demonstrating the Fission Workflows feature, each highlighting a different capability: - order-pipeline: e-commerce checkout — Task chaining, Parallel fraud/stock screening, Choice routing, payment retry with backoff, and catch on typed errors with resultPath document merging. Six deterministic inputs, one per route (fulfil, retry-then-fulfil, decline, high-fraud, out-of-stock, invalid). - batch-enrichment: CRM lead scoring — Map fan-out over an array with maxConcurrency and an ordered join feeding an aggregation step. - payment-dunning: subscription recovery — durable Wait timers between charge attempts, catch-driven business routing, and run history. Functions are plain Fission functions (nothing workflow-specific); all return JSON objects (the node env body-parser is strict) with business-plausible logic. Each example has a README, a workflow.yaml, and deterministic inputs. examples.json gains the three entries. Verified end to end on a kind cluster: all example routes reach their expected terminal state, including concurrent parallel joins and durable restart-resume. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
|
Tick the box to add this pull request to the merge queue (same as
|
Run operations moved under `fission workflow runs` (list/describe/history/ cancel) so a run name is never mistaken for a workflow name. Update the example READMEs to the new commands: fission workflow runs list --workflow <wf> fission workflow runs describe --name <run> fission workflow runs history --name <run> Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
`workflow graph --open` draws the diagram in a browser from an ephemeral local server (the graph never leaves the machine), and `workflow runs graph --name <run> --open` colors every state by what that run did — the visual answer to "where did this run stop". Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
What
Three real business-process examples for the Fission Workflows feature (RFC-0022), under
miscellaneous/workflows/, plus theirexamples.jsonentries.order-pipeline/resultPathmergingbatch-enrichment/maxConcurrency, ordered join → aggregationpayment-dunning/Each example is a plain set of Fission functions + a
Workflowmanifest + deterministic inputs and a README. Functions return JSON objects (the node env body-parser is strict) with business-plausible logic — no stubs.Verified end to end on a kind cluster
total: 6, segmented).resultPathpreserves the subscription id).Fission.BranchFailed), a 6-run concurrent burst (all succeed), and controller-restart mid-Wait (durable resume, timer fires exactly once).Note
The Workflows feature itself is in flight (fission/fission#3587); these examples are its companion and target that feature once released.
🤖 Generated with Claude Code