Skip to content

Feature/ Get upstream task ids by state#41506

Closed
romsharon98 wants to merge 112 commits intoapache:v2-10-stablefrom
romsharon98:feature/upstream-by-state
Closed

Feature/ Get upstream task ids by state#41506
romsharon98 wants to merge 112 commits intoapache:v2-10-stablefrom
romsharon98:feature/upstream-by-state

Conversation

@romsharon98
Copy link
Contributor

@romsharon98 romsharon98 commented Aug 15, 2024

this PR add an ability to get all upstream tasks by state.
the current state is that user can get only upstream tasks without any state.

this can solve issues like this https://stackoverflow.com/questions/73740427/airflow-how-to-get-list-of-upstream-failed-tasks


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

@romsharon98 romsharon98 force-pushed the feature/upstream-by-state branch from 4aad541 to 0742aac Compare August 18, 2024 08:19
@eladkal eladkal added this to the Airflow 3.0.0 milestone Aug 18, 2024
@eladkal eladkal added type:improvement Changelog: Improvements type:new-feature Changelog: New Features and removed type:improvement Changelog: Improvements labels Aug 18, 2024
@potiuk
Copy link
Member

potiuk commented Aug 18, 2024

I am not sure if we want to add this -> generally speaking, I think we want to get rid of the TaskInstance as model being available and used in Airflow 3 and use Airflow-sdk (with AIP-72) - but that is pending POC from @ashb so I am not sure if we will still be using TaskInstance for this kind of retrieval (especially that Session is passed in the method).

ephraimbuddy and others added 2 commits August 20, 2024 15:00
We should recommend that users reserialize DAGs after finishing their
downgrades - the older version may have a different representation and
can cause odd failures.
jscheffl and others added 26 commits August 20, 2024 15:00
…r and policy removal (apache#41550)

* airflow deprecated settings session_lifetime_days, force_log_out_after and policy removal

* news fragment added

* news fragment updated

* news fragment updated

* news fragment updated
* smtp email user and password deprecated config removal

* smtp email user and password deprecated config removal

* news fragment added

* smtp email user and password deprecated config removal
…pache#41488)

When running tests for providers with old Airflow versions, we have
to make sure to uninstall all packages before installing old Airflow
versions - because some of the packages can be installed by new
Airflow version and they are missing in the old Airflow version.

This has already happened in apache#41402 with methodtools.

This PR adds `--clean-airflow-installation` flag to relevant breeze
commands that install other airflow version. This is quite a bit
slower as it requires to uninstall and reinstall packages so we
do not set it by default.
…apache#41096)

* processor_poll_interval deprecated parameter usage removal

* news fragment added

* news fragment added

* news fragment added

* Update newsfragments/41096.significant.rst

Co-authored-by: Jarek Potiuk <jarek@potiuk.com>

* Update 41096.significant.rst

---------

Co-authored-by: Jarek Potiuk <jarek@potiuk.com>
* decorators deprecated apply_defaults removal

* news fragment added
* Add changelog for airflow python client 2.10.0

* Update client version
Python3-saml is an optional dependency of Amazon provider and in
case of Airflow 2.9 tests python3-saml is not installed yet, so we
should skip the tests in case it is not.
Co-authored-by: raphaelauv <raphaelauv@users.noreply.github.com>

---------

Co-authored-by: Vincent <97131062+vincbeck@users.noreply.github.com>
Co-authored-by: raphaelauv <raphaelauv@users.noreply.github.com>
@romsharon98
Copy link
Contributor Author

this PR add an ability to get all upstream tasks by state. the current state is that user can get only upstream tasks without any state.

this can solve issues like this https://stackoverflow.com/questions/73740427/airflow-how-to-get-list-of-upstream-failed-tasks

I open a new PR with target branch v2-10-stabel.

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

Labels

type:new-feature Changelog: New Features

Projects

None yet

Development

Successfully merging this pull request may close these issues.