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

Avoid re-fetching DAG run in TriggerDagRunOperator #27635

Merged
merged 11 commits into from
Nov 16, 2022

Conversation

Adityamalik123
Copy link
Contributor

We need to fix TriggerDagRunOperator when passed following:
reset_dag_run=True
execution_date=SomeDate and
trigger_run_id = **None**

The current code considers DagRunType 'MANUAL' by default in case trigger_run_id is None. As mentioned in this issue [https://github.com//issues/27299], There can be a case where we can have DagRunType 'SCHEDULED' with the similar scenario.


^ 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.

@boring-cyborg boring-cyborg bot added area:API Airflow's REST/HTTP API area:core-operators Operators, Sensors and hooks within Core Airflow labels Nov 12, 2022
@Adityamalik123 Adityamalik123 marked this pull request as ready for review November 12, 2022 20:00
@uranusjr uranusjr changed the title TriggerDagRunOperator task fails with index out of range exception while trying to reset dag run Avoid re-fetching DAG run in TriggerDagRunOperator Nov 16, 2022
@uranusjr uranusjr merged commit 4637c9e into apache:main Nov 16, 2022
@boring-cyborg
Copy link

boring-cyborg bot commented Nov 16, 2022

Awesome work, congrats on your first merged pull request!

@ephraimbuddy ephraimbuddy added the type:bug-fix Changelog: Bug Fixes label Nov 16, 2022
@eladkal eladkal added this to the Airflow 2.4.4 milestone Nov 16, 2022
@ephraimbuddy ephraimbuddy modified the milestones: Airflow 2.4.4, Airflow 2.5.0 Nov 23, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area:API Airflow's REST/HTTP API area:core-operators Operators, Sensors and hooks within Core Airflow type:bug-fix Changelog: Bug Fixes
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

4 participants