-
Notifications
You must be signed in to change notification settings - Fork 16
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
Adds support for running integration tests against Airflow #1204
Adds support for running integration tests against Airflow #1204
Conversation
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.
Looks good! Just a couple robustness concerns. Out of curiosity, how long does a full run take?
506e4bc
to
7ecd07a
Compare
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.
Cool, just a couple tiny nits.
@@ -211,6 +234,12 @@ def delete_all_flows(client: aqueduct.Client) -> None: | |||
else: | |||
print("Successfully deleted workflow %s" % flow_name) | |||
|
|||
# Try deleting Airflow DAG file if it exists | |||
# TODO - Only do this for Airflow workflows |
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.
Should we make a task for this TODO?
Describe your changes and why you are making these changes
This PR adds initial support for running integration tests against Airflow. It has a setup script for starting a local Airflow instance. It also adds logic for manually copying the Airflow DAG file to the appropriate folder.
There is still follow on work that needs to be done before these tests can be run on Github actions:
Related issue number (if any)
ENG 2116
Tests
Ran the basic flow_test locally and uncovered the syncing bug.
Loom demo (if any)
Checklist before requesting a review
python3 scripts/run_linters.py -h
for usage).run_integration_test
: Runs integration testsskip_integration_test
: Skips integration tests (Should be used when changes are ONLY documentation/UI)