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

[Feature] Extend EXECUTION_MODE.AIRFLOW_ASYNC for dbt-databricks adapter #1513

Open
1 task
pankajkoti opened this issue Feb 6, 2025 · 0 comments
Open
1 task
Labels
area:execution Related to the execution environment/mode, like Docker, Kubernetes, Local, VirtualEnv, etc enhancement New feature or request execution:async Related to the Async execution mode profile:databricks Related to Databricks ProfileConfig triage-needed Items need to be reviewed / assigned to milestone

Comments

@pankajkoti
Copy link
Contributor

Description

Continuing the work introduced in Cosmos 1.7 to support executing dbt project resources in a deferrable fashion using Airflow provider operators, this feature aims to extend EXECUTION_MODE.AIRFLOW_ASYNC to the dbt-databricks adapter.

Initially, this approach was implemented for BigQuery and refined through PRs #1474 and #1483 to ensure robustness. The next step is to explore how we can extend this functionality to Databricks, leveraging its capabilities to execute dbt models asynchronously while integrating seamlessly with Airflow’s deferrable operators.

Explore how we can utilize existing deferrable operators from the Apache Airflow Databricks provider or astronomer-providers. If suitable operators are unavailable, consider adding the necessary components to the Cosmos codebase to enable deferrable execution efficiently and accelerate development.

Use case/motivation

This enhancement will improve efficiency, reduce resource consumption, and provide users with a more scalable and optimized way to run dbt projects on Databricks within Airflow.

Related issues

No response

Are you willing to submit a PR?

  • Yes, I am willing to submit a PR!
@pankajkoti pankajkoti added enhancement New feature or request execution:async Related to the Async execution mode triage-needed Items need to be reviewed / assigned to milestone labels Feb 6, 2025
@dosubot dosubot bot added area:execution Related to the execution environment/mode, like Docker, Kubernetes, Local, VirtualEnv, etc profile:databricks Related to Databricks ProfileConfig labels Feb 6, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area:execution Related to the execution environment/mode, like Docker, Kubernetes, Local, VirtualEnv, etc enhancement New feature or request execution:async Related to the Async execution mode profile:databricks Related to Databricks ProfileConfig triage-needed Items need to be reviewed / assigned to milestone
Projects
None yet
Development

No branches or pull requests

1 participant