Description
Run a Data Health (Janitor) rule as a workflow step. Works on ANY system database (SQLite/Postgres/MySQL/MSSQL/DuckDB). Single mode to apply a specific rule, loop mode to run all enabled rules.
action_janitor_cleanup · action · Utility · Available · v1.0.0
Run a Data Health (Janitor) rule as a workflow step. Works on ANY system database (SQLite/Postgres/MySQL/MSSQL/DuckDB). Single mode to apply a specific rule, loop mode to run all enabled rules.
Fields shown in the editor when configuring the node. Generated directly from the NodeDefconfigFields.
| Field | Type | Required | Default | Description |
|---|---|---|---|---|
modeModalità | enumsinglecycle | yes | single | single = scegli UNA regola sotto. cycle = esegui automaticamente TUTTE le regole abilitate per il tenant. Per il dettaglio delle regole disponibili, apri il pannello "🧹 Salute dati" dalla sidebar. |
ruleIdID Regola (solo modalità "single") | string | no | — system.runs.zombie | Identificatore stabile della regola da eseguire. Esempi built-in: system.runs.zombie, system.runs.corrupted_json, system.runs.truncated_steps, system.runs.orphan_checkpoint. Le DSL rule custom hanno id del tipo dsl_<nanoid>. Apri "🧹 Salute dati" → tab Regole per la lista completa. |
dryRunDry-run (anteprima, non modifica nulla) | boolean | no | false | Quando attivo: la rule esegue la detection ma NON sposta righe in quarantena. Il flow procede con rowsDetected popolato ma rowsQuarantined=0. Utile per validare pre-prod. Default OFF (esecuzione live). |
failOnDetectionFallisci il nodo se trova corruzioni | boolean | no | false | Quando attivo: se rowsQuarantined > 0, il nodo va in status="error" (porta error fires). Per workflow di compliance che devono bloccarsi se trovano dati corrotti. Default OFF: il nodo procede sempre, l'output rowsQuarantined è ispezionabile. |
maxRowsPerRunLimite righe per esecuzione | number | no | — usa il default della regola | Solo modalità "single". Override del maxRowsPerRun della regola. Lascia vuoto per usare il default configurato. Range: 1 — 100.000. |
paramsOverrideOverride parametri (JSON) | JSON object/array | no | — {"zombieThresholdMs": 600000} | Solo modalità "single". JSON object che sovrascrive i parametri specifici della regola per questa esecuzione. Esempio: {"zombieThresholdMs": 600000} per rendere "runs.zombie" più aggressiva (10 min invece di 30). Lascia vuoto per usare i parametri configurati. |
tagFilterFiltra per tag (CSV) | string | no | — critical,recovery | Solo modalità "cycle". CSV di tag — vengono eseguite solo le regole che hanno almeno uno di questi tag. Vuoto = tutte le regole abilitate. |
Fields available to downstream nodes via $node.<alias>.json.<field>:
successdetectioncleanerrorJSON snippet of the node as it appears in the workflow. Values are derived fromdefaultValue and from required parameters.
{
"id": "node-action_janitor_cleanup-1",
"defId": "action_janitor_cleanup",
"label": "Data health: clean table",
"config": {
"mode": "single",
"dryRun": false,
"failOnDetection": false
}
}Available now on all FlowForge plans. Try it free without a credit card.
Start freeBrowse all nodes