使用 DatabricksWorkflowTaskGroup 和 DatabricksNotebookOperator 的範例 DAG。
模組內容
-
tests.system.databricks.example_databricks_workflow.EXECUTION_TIMEOUT[source]
-
tests.system.databricks.example_databricks_workflow.DATABRICKS_CONN_ID[source]
-
tests.system.databricks.example_databricks_workflow.DATABRICKS_NOTIFICATION_EMAIL[source]
-
tests.system.databricks.example_databricks_workflow.GROUP_ID[source]
-
tests.system.databricks.example_databricks_workflow.USER[source]
-
tests.system.databricks.example_databricks_workflow.QUERY_ID[source]
-
tests.system.databricks.example_databricks_workflow.WAREHOUSE_ID[source]
-
tests.system.databricks.example_databricks_workflow.job_cluster_spec[source]
-
tests.system.databricks.example_databricks_workflow.dag[source]
-
tests.system.databricks.example_databricks_workflow.task_group[source]
-
tests.system.databricks.example_databricks_workflow.test_run[source]