perry2of5 opened a new pull request, #41601: URL: https://github.com/apache/airflow/pull/41601
This PR adds a callback to process messages from an Azure Service Bus. Right now, on main, the Azure Service Bus message receiver simply logs the messages received and returns. This PR preserves that default, but adds the ability to pass in a callback function with the signature ServiceBusMessage -> None which is applied to each message received. This change is made to both the general receiver and the subscription receiver. I'd like someone from the Airflow community to weigh in on if this is a good solution. To me, it seemed like the least intrusive way to add a hook to obtain the message contents. However, I'm not sure if it plays well with the Airflow Operator standards as I've barely been using Airflow for a month. Please let me know if you see any errors, omissions, or if I'm headed in the wrong direction. Thank you, Tim -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
