fix(processor): replace panic with graceful error in activePartitions - #7181
fix(processor): replace panic with graceful error in activePartitions#7181sriman0707 wants to merge 4 commits into
Conversation
|
Thank you @sriman0707 for contributing this PR. |
…ive-partitions-panic
|
This PR is considered to be stale. It has been open 20 days with no further activity thus it is going to be closed in 7 days. To avoid such a case please consider removing the stale label manually or add a comment to the PR. |
|
Hi maintainers, Just a friendly follow-up on this PR. I have completed the CLA requirements and kept the branch up to date with the latest I'd appreciate it if someone could take a look when you have time. If there are any changes, tests, or improvements you'd like me to make, I'm happy to update the PR. Thanks for your time and for maintaining RudderStack! |
|
Thanks for the PR @sriman0707
|
|
Thanks for asking!
|
Description
Replaces a
panic(err)call inprocessor.activePartitions()with graceful error handling.Previously, when the database connection was temporarily lost,
activePartitions()would panic. This panic terminated the runner's pinger goroutine, silently crashing the active event-processing loop.With this change, the handler logs the connection error, records a metric, and returns an empty partition list. This allows the pinger loop to gracefully retry fetching active partitions on the next tick once the database recovers.
Linear Ticket
N/A (External Open Source Contribution)
Security