Files
openobserve/tests
Subhra264 04f54a54cd test: Add tests for derived streams (#8084)
### **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>&nbsp; &nbsp; &nbsp; &nbsp;
&nbsp; &nbsp; &nbsp; &nbsp; </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>&nbsp;
</td>

</tr>
</table></td></tr></tr></tbody></table>

</details>

___
2025-08-21 18:56:34 +05:30
..
2024-09-22 17:57:47 +08:00