ironflow-worker 2.8.14

HTTP-based background worker for ironflow — polls the API and executes workflows
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

# ironflow-worker

HTTP-based background worker for **ironflow**. Polls the API server for pending workflow runs, executes them locally, and reports results back.

## How it works

1. The worker polls `GET /api/v1/internal/runs/next` for queued runs
2. Claims a run via `POST /api/v1/internal/runs/:id/claim`
3. Executes the workflow using the registered `WorkflowHandler`
4. Pushes step logs in real-time via `POST /api/v1/internal/runs/:id/logs`
5. Reports final status (completed/failed) back to the API

Communication is authenticated with a static `WORKER_TOKEN`.

## Feature flags

| Feature | Description |
|---------|-------------|
| `prometheus` | Expose worker execution metrics |
| `heartbeat` | Periodic heartbeat to the API server |

## Quick start

```rust,no_run
use std::sync::Arc;
use std::time::Duration;
use ironflow_worker::WorkerBuilder;
use ironflow_core::providers::claude::ClaudeCodeProvider;

async fn example() {
    let provider = Arc::new(ClaudeCodeProvider::default());
    let worker = WorkerBuilder::new("http://localhost:3000", "worker-token")
        .provider(provider)
        .poll_interval(Duration::from_secs(5))
        .build();

    worker.run().await.unwrap();
}
```

## License

MIT License - see [LICENSE](../LICENSE) for details.