Skip to content

Optimize deferred mode execution for wasb sensors - #31009

Merged
eladkal merged 3 commits into
apache:mainfrom
astronomer:optimize_wasb_sensor
May 23, 2023
Merged

eladkal merged 3 commits into
apache:mainfrom
astronomer:optimize_wasb_sensor

Conversation

@phanikumv

Copy link
Copy Markdown
Contributor

In deferrable mode for wasb sensors, we should first check if blob is available or not in the execute method and only defer if that is not successful. This way we don’t run an unnecessary deferral cycle if the condition is already true.

cc @dstandish


^ Add meaningful description above

Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named {pr_number}.significant.rst or {issue_number}.significant.rst, in newsfragments.

@phanikumv
phanikumv force-pushed the optimize_wasb_sensor branch from f1bae51 to 2d83d77 Compare May 3, 2023 02:25
Comment thread tests/providers/microsoft/azure/sensors/test_wasb.py Outdated
@phanikumv
phanikumv force-pushed the optimize_wasb_sensor branch 3 times, most recently from 4d9fefc to 143b324 Compare May 11, 2023 10:48
@phanikumv
phanikumv force-pushed the optimize_wasb_sensor branch from 143b324 to 3ede13b Compare May 14, 2023 15:11
@phanikumv
phanikumv force-pushed the optimize_wasb_sensor branch from 3ede13b to 2d30fbb Compare May 16, 2023 04:07
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.

6 participants