FlowBuilder — Workflows testés, versionnés, prouvés

1// Parallel workflow execution with resource locking
2async function executeWorkflow(wf: Workflow): Promise<RunResult> {
3  const dag = buildDAG(wf.nodes, wf.edges)
4  const visited = new Set<string>()
5  const results = new Map<string, NodeOutput>()
6
7  async function runNode(nodeId: string): Promise<void> {
8    if (visited.has(nodeId)) return
9    visited.add(nodeId)
10
11    // Run all upstream dependencies first (parallel)
12    const upstream = dag.getParents(nodeId)
13    await Promise.all(upstream.map(runNode))
14
15    const node = wf.nodes.find((n) => n.id === nodeId)!
16    const inputs = collectInputs(nodeId, results)
17
18    try {
19      const output = await executeNodeType(node, inputs)
20      results.set(nodeId, output)
21      await db.logs.create({ workflowId: wf.id, nodeId, output })
22    } catch (err) {
23      await notifyError(wf, nodeId, err)
24      throw err
25    }
26  }
27
28  const sinks = dag.getSinks()
29  await Promise.all(sinks.map(runNode))
30  return { success: true, results: Object.fromEntries(results) }
31}

1// Cron scheduler — distributed lock prevents double-execution
2class WorkflowScheduler {
3  private readonly lock: RedisLock
4
5  constructor(redis: Redis) {
6    this.lock = new RedisLock(redis, { ttl: 30_000 })
7  }
8
9  async tick(): Promise<void> {
10    const due = await db.workflows.findDue(new Date())
11
12    await Promise.allSettled(
13      due.map(async (wf) => {
14        const acquired = await this.lock.acquire(`wf:${wf.id}`)
15        if (!acquired) return // another instance is running it
16
17        try {
18          const run = await executeWorkflow(wf)
19          await db.runs.create({ workflowId: wf.id, ...run })
20          await db.workflows.updateNextRun(wf.id, wf.schedule)
21        } catch (err) {
22          await db.workflows.recordFailure(wf.id, String(err))
23          if (wf.alertOnFailure) await notifyError(wf, err)
24        } finally {
25          await this.lock.release(`wf:${wf.id}`)
26        }
27      })
28    )
29  }
30}