mirror of
https://github.com/openobserve/openobserve.git
synced 2026-11-06 16:09:41 +00:00
### **PR Type**
Tests, Enhancement
___
### **Description**
- Add derived stream e2e tests
- Create/delete pipelines via API helpers
- Validate trigger lifecycle and retries
- Cover invalid SQL evaluation behavior
___
### Diagram Walkthrough
```mermaid
flowchart LR
Create["Create test pipeline"] -- "POST /api/{org}/pipelines" --> List["List pipelines"]
List -- "GET /api/{org}/pipelines" --> TriggerOK["Trigger success path"]
List --> TriggerMaxRetries["Trigger max retries path"]
InvalidPipe["Create invalid pipeline"] -- "POST" --> DeleteField["Delete field from stream"]
DeleteField -- "PUT /streams/.../delete_fields" --> TriggerFail["Trigger evaluation failure"]
Cleanup["Cleanup pipelines"] -- "DB delete" --> End["Done"]
```
<details> <summary><h3> File Walkthrough</h3></summary>
<table><thead><tr><th></th><th align="left">Relevant
files</th></tr></thead><tbody><tr><td><strong>Tests</strong></td><td><table>
<tr>
<td>
<details>
<summary><strong>integration_test.rs</strong><dd><code>Add derived
stream pipeline E2E tests and helpers</code>
</dd></summary>
<hr>
tests/integration_test.rs
<ul><li>Import pipeline, derived stream, trigger types<br> <li> Add
helper to POST pipelines via API<br> <li> Add e2e tests for derived
stream success, not found, max retries<br> <li> Add e2e test for
evaluation failure with invalid SQL and cleanup</ul>
</details>
</td>
<td><a
href="https://github.com/openobserve/openobserve/pull/8084/files#diff-7ff815b68943f08bef79f083c09e55ca8c18db8e25033034b12fa31f1d43dab4">+480/-1</a>
</td>
</tr>
</table></td></tr></tr></tbody></table>
</details>
___