Skip to content

Fix AwaitMessageSensor not honoring timeout#62104

Open
Pranaykarvi wants to merge 1 commit intoapache:mainfrom
Pranaykarvi:fix-await-message-sensor-timeout
Open

Fix AwaitMessageSensor not honoring timeout#62104
Pranaykarvi wants to merge 1 commit intoapache:mainfrom
Pranaykarvi:fix-await-message-sensor-timeout

Conversation

@Pranaykarvi
Copy link

Ensure AwaitMessageSensor passes operator timeout directly to defer(), matching other deferrable sensors.

Adds regression test.

Fixes #62097

@Srabasti
Copy link
Contributor

Looks like static checks are failing. Please run prek locally in your branch before committing changes to Airflow Github repo, so ruff hook errors can be resolved automatically.

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.

Timeout parameter not respected in AwaitMessageSensor unless passed to defer()

3 participants

Comments