使用 DatabricksWorkflowTaskGroup 和 DatabricksNotebookOperator 的示例 DAG。
模块内容
-
tests.system.databricks.example_databricks_workflow.EXECUTION_TIMEOUT[源代码]
-
tests.system.databricks.example_databricks_workflow.DATABRICKS_CONN_ID[源代码]
-
tests.system.databricks.example_databricks_workflow.DATABRICKS_NOTIFICATION_EMAIL[源代码]
-
tests.system.databricks.example_databricks_workflow.GROUP_ID[源代码]
-
tests.system.databricks.example_databricks_workflow.USER[源代码]
-
tests.system.databricks.example_databricks_workflow.QUERY_ID[源代码]
-
tests.system.databricks.example_databricks_workflow.WAREHOUSE_ID[源代码]
-
tests.system.databricks.example_databricks_workflow.job_cluster_spec[源代码]
-
tests.system.databricks.example_databricks_workflow.dag[源代码]
-
tests.system.databricks.example_databricks_workflow.task_group[源代码]
-
tests.system.databricks.example_databricks_workflow.test_run[源代码]