Skip to content

Conversation

@perry2of5
Copy link
Contributor

@perry2of5 perry2of5 commented Dec 20, 2024

This commit refactors the logic to create a subscription into the hook. The operators should not be accessing the connection to Azure Service Bus directly. This code belongs in the hook to promote reuse.

In addition, it allows the caller to pass a RuleFilter to apply to the subscription to limit which messages are sent to the subscription.

@dabla: this addresses part of your comments on PR 44675

@perry2of5
Copy link
Contributor Author

The build failure appears unrelated to my re-wording of the comment :)

This commit refactors the logic to create a subscription into the
hook. The operators should not be accessing the connection to Azure
Service Bus directly. This code belongs in the hook to promote reuse.
@potiuk
Copy link
Member

potiuk commented Dec 21, 2024

Yeah. Fixed in main (including #45131 fixing selective checks that caused broken main). Rebased it now.

@shahar1 shahar1 merged commit b29a16c into apache:main Dec 21, 2024
64 checks passed
@perry2of5
Copy link
Contributor Author

perry2of5 commented Dec 22, 2024 via email

@dabla
Copy link
Contributor

dabla commented Dec 22, 2024

Thank you to both of you!

Nicely done, good work!

@perry2of5 perry2of5 deleted the move-asb-create-subscription-to-hook branch December 30, 2024 17:46
got686-yandex pushed a commit to got686-yandex/airflow that referenced this pull request Jan 30, 2025
…45125)

* Move create_subscription to hook

This commit refactors the logic to create a subscription into the
hook. The operators should not be accessing the connection to Azure
Service Bus directly. This code belongs in the hook to promote reuse.

* Fix comment to match code
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants