Commit ac74c2a
fix: pass params.message directly as initial_message to prevent orphan SUBMITTED rows
When a producer fails before emitting any events, the task is created
via ensure_task_id() using the initial_message passed to TaskManager.
Using params.message directly instead of request_context.message makes
the data flow more explicit and avoids depending on RequestContext's
internal implementation.
Fixes #1067
Co-Authored-By: Claude <noreply@anthropic.com>1 parent 086d70f commit ac74c2a
1 file changed
Lines changed: 1 addition & 1 deletion
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
231 | 231 | | |
232 | 232 | | |
233 | 233 | | |
234 | | - | |
| 234 | + | |
235 | 235 | | |
236 | 236 | | |
237 | 237 | | |
| |||
0 commit comments