Migrating logic from Airflow DAGs to Databricks Workflow
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
01-07-2025 04:06 AM
Hello community,
I'm planning to migrate some logics of Airflow DAGs on Databricks Workflow. But, I was facing out to some doubts that I have in order to migrate (to find the respective) the logic of my actual code from DAGs to Workflow.
There are two points:
- https://airflow.apache.org/docs/apache-airflow/stable/authoring-and-scheduling/dynamic-task-mapping...., in particular how is it possible to replicate using Workflows the .expand() function?
- How to get something like: context = get_current_context() https://airflow.apache.org/docs/apache-airflow/stable/_api/airflow/operators/python/index.html#airfl...