Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion server/pipeline/pipeline-params.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,10 @@ task = PipelineTask(pipeline, params=params)
Period between heartbeats in seconds (when heartbeats are enabled).
</ParamField>

<ParamField path="heartbeats_monitor_secs" type="float" default="10.0">
Timeout in seconds before warning about missed heartbeats.
</ParamField>

<ParamField path="enable_metrics" type="bool" default="False">
Whether to enable metrics collection for pipeline performance.
</ParamField>
Expand Down Expand Up @@ -108,7 +112,8 @@ Pipeline heartbeats provide a way to monitor the health of your pipeline by send
```python
params = PipelineParams(
enable_heartbeats=True,
heartbeats_period_secs=2.0, # Send heartbeats every 2 seconds
heartbeats_period_secs=2.0, # Send heartbeats every 2 seconds
heartbeats_monitor_secs=15.0, # Warn if heartbeat takes more than 15 seconds
enable_metrics=True
)
```
Expand Down
Loading