Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Treat AMQP library exceptions as actual errors #4212

Merged
merged 1 commit into from
May 12, 2024

Conversation

satta
Copy link
Contributor

@satta satta commented May 12, 2024

This ensures that the amqp operator actually fails in cases such as network disconnects, which otherwise would not cause pipelines with amqp connectors to restart on failure.

@mavam mavam added connector Loader and saver improvement An incremental enhancement of an existing feature labels May 12, 2024
@dominiklohmann dominiklohmann self-requested a review May 12, 2024 10:12
plugins/amqp/src/plugin.cpp Outdated Show resolved Hide resolved
plugins/amqp/src/plugin.cpp Show resolved Hide resolved
This ensures that the `amqp` operator actually fails in cases such as
network disconnects, which otherwise would not cause pipelines with
amqp connectors to restart on failure.
@satta satta force-pushed the topic/robust-amqp-errors branch from 69328a4 to d7cbf84 Compare May 12, 2024 10:36
@dominiklohmann dominiklohmann merged commit 046cc0f into tenzir:main May 12, 2024
22 of 24 checks passed
@satta satta deleted the topic/robust-amqp-errors branch May 12, 2024 10:52
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
connector Loader and saver improvement An incremental enhancement of an existing feature
Projects
None yet
3 participants