-
Notifications
You must be signed in to change notification settings - Fork 186
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
Move DbtRunner
related functions into dbt/runner.py
module
#1480
Conversation
✅ Deploy Preview for sunny-pastelito-5ecb04 ready!
To edit notification comments on pull requests, go to your Netlify site configuration. |
Deploying astronomer-cosmos with
|
Latest commit: |
006cc1d
|
Status: | ✅ Deploy successful! |
Preview URL: | https://6ef0ef85.astronomer-cosmos.pages.dev |
Branch Preview URL: | https://issue-865-refactor.astronomer-cosmos.pages.dev |
4afa986
to
0f9f35e
Compare
DbtRunner
utility functions into dbt/runner.py
moduleDbtRunner
-related functions into dbt/runner.py
module
DbtRunner
-related functions into dbt/runner.py
moduleDbtRunner
related functions into dbt/runner.py
module
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. Great refactor and organization! I’ve added a few minor questions and suggestions in-line.
52fcba4
to
a7b49b3
Compare
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #1480 +/- ##
==========================================
+ Coverage 96.57% 96.60% +0.03%
==========================================
Files 73 74 +1
Lines 4374 4414 +40
==========================================
+ Hits 4224 4264 +40
Misses 150 150 ☔ View full report in Codecov by Sentry. |
Previously, @jbandoro added support for Cosmos to use
dbtRunner
to execute dbt commands in the Airflow worker nodes when usingExecutionMode.LOCAL
instead of Python's subprocess #850. This change significantly improved Cosmos resource utilisation in worker nodes.The first step to implementing support to use
dbtRunner
during DAG parsing (ticket #865) when usingLoadMode.DBT_LS
is to extractdbtRunner
methods somewhere it can be reused bygraph.py
and is not specific tooperators.py
.This PR does the following:
dbt/runner.py
dbtRunner
related functions to this module, refactoring them as neededoperators/local.py
to use the newly introduced methodsRelated: #865