-
Notifications
You must be signed in to change notification settings - Fork 6.5k
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
cleanup: Upgrade Composer samples to Airflow 2.0 #5782
Conversation
You are about to delete the following sample browser pages.
Here is the summary of changes. You are about to add 1 region tag.
You are about to delete 3 region tags.
This comment is generated by snippet-bot.
|
78a9ae2
to
7c60e1c
Compare
YAY #5806 made the tests pass!! This is only red because I'm bad at remembering to run lint locally!!!!!!!!!!!!! |
05cb6f9
to
f87bcac
Compare
Just looked at the dataflow/dataproc tutorials, LGTM! |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM!
omg I have no idea how I made this mess with adding these requirements files. I'll fix later today 🤦🏻♀️ |
affa66f
to
207371f
Compare
207371f
to
f9447fa
Compare
I have been talking to TWs and need to move the Airflow 1 versions to a "legacy samples" folder |
Actually, I'll do the legacy samples thing in a separate PR. I'm ready for you, @dinagraves ! :) |
…#5782) * modify dag_test_utils to point to branch; add airflow 2 changes * upgrade airflow_db_cleanup to Airflow 2.0 * upgrade hadoop tutorial to Airflow 2.0 * upgrade kubernetespodoperator to Airflow 2.0 * upgrade dataproc workflow template to Airflow 2.0 * remove bashoperator python2 example * upgrade DataflowTemplateOperator tutorial to 2.0 * WIP: upgrade bq_notify to Airflow 2 * upgrade bq_copy_across_locations to Airflow 2.0 * upgrade connections to Airflow 2 * more airflow 2.0 migration * db reset update * copy constraints from Airflow * update noxfile config * update constraints to py-3.8 * add pip version override * upgrade simple to airflow 2 * fix lint * bqnotify cleanup * add blog/ conftest * fix license header * more license header fixes * license again * remove unused import from blog conftest * remove unused requirements * remove script used by dag deleted in this PR * Add clarifying comment about email operator * add newline back to csv * fix presumed typo Co-authored-by: Dina Graves Portman <dinagraves@google.com>
Description
This PR follows best practices for upgrading DAGs from Airflow 1 to Airflow 2. Changes included:
conftest.py
to theblogs
folder. For now, that DAG will stay at using Airflow 1.0, and we need to initialize a compatible DB for those tests separate from theworkflows
DB.workflows/requirements-test.txt
contrib
toproviders
bash_operator
->bash
)If you would like access to my Composer environment to see the DAGs deployed, please let me know. Otherwise, here is a screenshot showing successful dag runs across the board
Fixes #5171
DataflowTemplateOperator tutorial update in CL/371792521 - removed instructions for setting
gce_region
Airflow variable (@sofisl )CHANGE NOT ADDRESSED - I need to look further at the DAG example we have triggered by GCF. That will be addressed in an upcoming PR.
Note: It's a good idea to open an issue first for discussion.
Checklist
nox -s py-3.6
(see Test Environment Setup)nox -s lint
(see Test Environment Setup)