feat(forks): CLI --fork-triggers flag, fork-trigger docs, skill update

- Adds --fork-triggers boolean to wmill workspace fork; passes
  fork_triggers through to the create_fork API call.
- New docs/fork-triggers.md describing the model end-to-end (default,
  opt-in clone, merge-direction filter, conflict warning, future
  runtime-suffix work).
- Updates the adding-a-trigger SKILL.md to mention the fork-export
  ignore-keys participation and the clone_triggers_and_schedules
  block that new trigger kinds must extend.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
hugocasa
2026-04-29 18:52:11 +02:00
parent e6e2afa3f4
commit 0f00de6eee
4 changed files with 111 additions and 1 deletions
+3 -1
View File
@@ -111,7 +111,9 @@ Regenerate frontend client: `npm run generate-backend-client` from `frontend/`.
**`backend/windmill-api-workspaces/src/workspaces.rs`** — add `{kind}_used: bool` to the `UsedTriggers` struct and add an `EXISTS(SELECT 1 FROM {kind}_trigger …)` to the `get_used_triggers` query.
**`backend/windmill-api/src/workspaces_export.rs`** — add export block mirroring gcp's (export lists all triggers, serializes them to YAML/JSON).
**`backend/windmill-api/src/workspaces_export.rs`** — add export block mirroring gcp's (export lists all triggers, serializes them to YAML/JSON). The block re-uses the `trigger_ignore_keys` variable so the new kind automatically participates in fork-export stripping (`mode` field is omitted when the source workspace is a fork — keeps fork→parent merges from flipping the parent's enabled state).
**Fork cloning (`clone_triggers_and_schedules` in workspaces.rs)** — add an `INSERT INTO {kind}_trigger ... SELECT ...` block that copies all rows from the parent workspace, forcing `mode = 'disabled'::TRIGGER_MODE`. This runs only when the user opts in via `fork_triggers=true` at fork creation. Forgetting this means users can't carry `{kind}` triggers into their forks.
## 6.5 Hardcoded trigger-kind arrays (silent-failure hotspots)
+2
View File
@@ -14,6 +14,7 @@ async function createWorkspaceFork(
createWorkspaceName: string | undefined;
color: string | undefined;
datatableBehavior: string | undefined;
forkTriggers: boolean | undefined;
yes: boolean | undefined;
},
workspaceName: string | undefined,
@@ -231,6 +232,7 @@ async function createWorkspaceFork(
name: opts.createWorkspaceName ?? trueWorkspaceId,
color: forkColor,
forked_datatables: forkedDatatables,
fork_triggers: opts.forkTriggers ?? false,
},
});
+4
View File
@@ -772,6 +772,10 @@ const command = new Command()
"--datatable-behavior <behavior:string>",
"How to handle datatables: skip, schema_only, or schema_and_data (default: interactive prompt)"
)
.option(
"--fork-triggers",
"Clone every trigger and schedule from the parent into the fork (always disabled). Defaults to off."
)
.option("-y --yes", "Skip interactive prompts (defaults datatable behavior to 'skip')")
.action(createWorkspaceFork as any)
.command("delete-fork")
+102
View File
@@ -0,0 +1,102 @@
# Triggers and schedules in workspace forks
A workspace fork is a developer-controlled copy of a parent workspace, used to
test changes before merging back via git sync. Triggers and schedules in a
fork need special handling for two reasons:
1. **Listener take-over**: most trigger kinds (Kafka, Postgres, MQTT, NATS,
SQS, GCP, Azure) attach to a stateful upstream resource. Two listeners
sharing the same identifier compete for events.
2. **Merge round-trip**: every change made in a fork can flow back to the
parent through git sync. If the fork sets a trigger to `disabled`, that
value would otherwise overwrite the parent's `enabled` state on merge.
## Default behavior — `fork_triggers = false`
Forks created without opting in start trigger-empty. The fork has no rows in
any `*_trigger` table or in `schedule`. This is the safest default: nothing
in the fork can compete with the parent or alter the parent's state on merge.
## Opt-in cloning — `fork_triggers = true`
When the user ticks "Clone triggers and schedules" (UI) or passes
`--fork-triggers` (CLI), fork creation also runs `clone_triggers_and_schedules`
which copies every row from each `*_trigger` table and from `schedule` into
the fork. Two invariants apply:
- **Always disabled.** The clone forces `mode='disabled'::TRIGGER_MODE` on
triggers and `enabled=false` on schedules, regardless of the parent's
state. The user re-enables manually in the fork.
- **Listener identifiers copied verbatim.** Stored values for
`group_id`, `replication_slot_name`, `subscription_name`, `client_id`,
`consumer_name`, etc. are copied 1:1. Until the runtime-suffix work
ships (see below), this means enabling a cloned listener in the fork
would compete with the parent.
`native_trigger` (Nextcloud, Google Drive, GitHub) is intentionally **not
cloned**. Those triggers manage external webhook state we don't want
duplicated.
## Merge-direction filter (always on)
Whenever the source workspace ID matches `wm-fork-*`, the tarball export at
`/api/w/{workspace}/workspaces/tarball` strips fork-local fields:
- `mode` from every `*_trigger` row
- `enabled` from every `schedule` row
The trigger update handler complements this: when an incoming `update_trigger`
request omits both `mode` and `enabled`, the existing DB value is preserved
instead of falling back to the BaseTriggerData default of `Enabled`. This
means the fork→parent merge cannot flip the parent's operational state, even
if the fork has an explicit (locally-disabled) state for that path.
The schedule `EditSchedule` payload already lacks an `enabled` field, so its
update path is naturally safe.
## Conflict warning on enable
The `set_*_trigger_mode` and `set_schedule_enabled` endpoints check whether
the parent workspace has the same path enabled. If so, they reject the
request with an error string of the shape:
```
fork-conflict:<kind>:<parent_workspace_id>
```
The frontend's `withForkConflictRetry` helper detects this prefix, asks the
user to confirm via a dialog, and re-issues the call with `force: true` if
the user agrees. The CLI sees the raw error.
This warning is the *durable* solution for trigger kinds where the conflict
cannot be eliminated:
- **SQS** — the queue *is* the event source; two consumers will compete for
messages no matter what.
- **GCP-Existing subscription** — same as SQS.
- **Schedule** — both crons fire on the same wall-clock; deduplication has
to happen in the script logic.
For the kinds that *can* be auto-namespaced (see below), the warning is the
short-term placeholder until that work lands.
## Future work — runtime listener suffix (Phase 3)
A follow-up PR will append a fork-specific suffix to the upstream identifier
at runtime for the kinds that support it:
| Kind | Identifier | Notes |
|---|---|---|
| Kafka | `group_id` | Two consumer groups never share messages. |
| MQTT | `client_id` | Brokers reject duplicate client_ids; suffix avoids that. |
| NATS | durable consumer name | Fork consumes independently. |
| Postgres | `replication_slot_name` + `publication_name` | Fork auto-creates its own publication on enable, drops on disable / fork delete. |
| Azure Event Grid | `subscription_name` | `manage_azure_subscription` creates the suffixed sub in Azure. |
| GCP Pub/Sub (CreateNew) | `subscription_id` | `manage_google_subscription` creates the suffixed sub. |
The suffix is invisible in the stored row and never reaches the parent on
merge — the merge-direction filter strips identifier columns too.
`Phase 3` also adds cleanup-on-fork-delete hooks for the upstream resources
(Azure / GCP / Postgres publication) so deleted forks don't leak external
state.