mirror of
https://github.com/openobserve/openobserve.git
synced 2026-11-04 08:09:27 +00:00
### **PR Type**
Bug fix, Enhancement
___
### **Description**
- Add retry on enrichment table fetch failure
- Propagate errors instead of swallowing them
- Improve logging for fetch outcomes
- Adjust log levels to info for visibility
___
### Diagram Walkthrough
```mermaid
flowchart LR
A["watch() listener"] -- "fetch table" --> B["get_enrichment_table()"]
B -- "calls" --> C["get_enrichment_table_data()"]
C -- "success with hits" --> D["return hits"]
C -- "success no hits" --> E["return empty vec"]
C -- "error" --> F["return Err (no swallow)"]
F -- "watch retries once" --> B
G["get_enrichment_table_json()"] -- "decide source" --> H["remote via get_enrichment_table_data()"]
G -- "or" --> I["local cache retrieve()"]
```
<details> <summary><h3> File Walkthrough</h3></summary>
<table><thead><tr><th></th><th align="left">Relevant
files</th></tr></thead><tbody><tr><td><strong>Bug
fix</strong></td><td><table>
<tr>
<td>
<details>
<summary><strong>enrichment_table.rs</strong><dd><code>Error propagation
and retry in enrichment table DB layer</code> </dd></summary>
<hr>
src/service/db/enrichment_table.rs
<ul><li>Add detailed success/no-hit logs.<br> <li> Change error handling
to return Err instead of empty vec.<br> <li> Improve error log message
formatting.<br> <li> Implement single retry in watch() before giving
up.</ul>
</details>
</td>
<td><a
href="https://github.com/openobserve/openobserve/pull/8720/files#diff-6ce27ddf8a0d8b4e790bda90d088ff692a5da31a8d330beea8a9dd843294572b">+23/-4</a>
</td>
</tr>
</table></td></tr><tr><td><strong>Enhancement</strong></td><td><table>
<tr>
<td>
<details>
<summary><strong>mod.rs</strong><dd><code>Increase logging level for
enrichment table source</code>
</dd></summary>
<hr>
src/service/enrichment/mod.rs
<ul><li>Elevate debug logs to info for fetch source.<br> <li> Clarify
remote vs local fetch logging.<br> <li> No functional logic changes
beyond logging.</ul>
</details>
</td>
<td><a
href="https://github.com/openobserve/openobserve/pull/8720/files#diff-0ea1823eb8a3a9845cde8bb2264ccdb749fad5be6d9acda8b17d76b2dbfdcc9f">+2/-2</a>
</td>
</tr>
</table></td></tr></tr></tbody></table>
</details>
___