Skip to content

Sync back#78

Merged
siklosid merged 237 commits intosiklosid:masterfrom
chocoapp:master
Mar 23, 2026
Merged

Sync back#78
siklosid merged 237 commits intosiklosid:masterfrom
chocoapp:master

Conversation

@siklosid
Copy link
Copy Markdown
Owner

Merging back to original

siklosid and others added 30 commits September 30, 2023 15:45
claudiazi and others added 27 commits August 8, 2025 15:12
…-deferrable-batch

Feature/data 2449 improve failed deferrable batch
…_version

Relaxing click version to avoid conflict with dbt
…_dagger

Feature/data 2567 python upgrade dagger
Required for the new DLT creator which uses DatabricksRunNowOperator
and DatabricksHook from apache-airflow-providers-databricks.
Required for DLT creator to work in production.
- Add type hints and docstrings to DatabricksIO
- Improve error handling in DatabricksDLTCreator with ImportError support
- Add validation for empty job_name in DatabricksDLTCreator
- Add comprehensive test coverage for DatabricksIO, DatabricksDLTTask, and DatabricksDLTCreator
- All Databricks components now have 100% test coverage
Prefer explicit properties over getattr for type safety and better IDE support.
DATA-2637 Implement DLT creator for Databricks Delta Live Tables
Rename task type and operator creator to match the generated task YAML
files from the DLT task generator plugin.

Files renamed:
- databricks_dlt_task.py -> declarative_pipeline_task.py
- databricks_dlt_creator.py -> declarative_pipeline_creator.py
- test_databricks_dlt_task.py -> test_declarative_pipeline_task.py
- test_databricks_dlt_creator.py -> test_declarative_pipeline_creator.py
- databricks_dlt_task.yaml -> declarative_pipeline_task.yaml

Changes:
- Class names: DatabricksDLTTask -> DeclarativePipelineTask
- Class names: DatabricksDLTCreator -> DeclarativePipelineCreator
- ref_name: "databricks_dlt" -> "declarative_pipeline"
- Updated imports in factory files
Add declarative_pipeline task type for DLT pipelines
The on_failure_callback on DatabricksRunNowOperator was overriding
the DAG-level callback (Slack alerts) set in default_args. Build a
composite callback that cancels the Databricks run AND invokes the
DAG-level alert callback.
…lerts

Fix Slack alerts not firing for declarative pipeline tasks
@siklosid siklosid closed this Mar 23, 2026
@siklosid siklosid reopened this Mar 23, 2026
@siklosid siklosid merged commit 90de4e0 into siklosid:master Mar 23, 2026
2 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants