Commit 07729df
committed
input_log: handle deferred chunk creation in threaded inputs with conditional routing
Modify route_payload_apply_outputs() to gracefully handle the case where
chunks don't exist yet in threaded mode due to asynchronous ring buffer
processing. This prevents data loss for threaded inputs using conditional
routing by falling back to normal routing instead of treating missing chunks
as fatal errors.
Signed-off-by: Eduardo Silva <eduardo@chronosphere.io>1 parent aa70b3e commit 07729df
1 file changed
Lines changed: 8 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
115 | 115 | | |
116 | 116 | | |
117 | 117 | | |
118 | | - | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
119 | 126 | | |
120 | 127 | | |
121 | 128 | | |
| |||
0 commit comments