DatabricksReposUpdateOperator¶

使用 DatabricksReposUpdateOperator 來更新現有 Databricks Repos 中的程式碼至指定的 Git 分支或標籤，透過 api/2.0/repos/ API 端點。

使用 Operators¶

通常此 operator 用於在 Databricks 工作執行前更新其原始碼。要使用此 operator，您需要提供 branch 或 tag，以及 repo_path 或 repo_id 其中之一。

參數	輸入
branch: str	要更新至的現有 Git 分支名稱（若未提供 `tag` 則為必要）。
tag: str	要更新至的現有 Git 標籤名稱（若未提供 `branch` 則為必要）。
repo_path: str	現有 Databricks Repos 的路徑，例如 `/Repos/<user_email>/repo_name`（若未提供 `repo_id` 則為必要）。
repo_id: str	現有 Databricks Repos 的 ID（若未提供 `repo_path` 則為必要）。
databricks_conn_id: string	要使用的 Airflow 連線名稱。
databricks_retry_limit: integer	若 Databricks 後端無法連線時，重試次數。
databricks_retry_delay: decimal	重試之間等待的秒數。

範例¶

透過指定路徑更新 Databricks Repo¶

以下為 DatabricksReposUpdateOperator 的使用範例

tests/system/databricks/example_databricks_repos.py[原始碼]

    # Example of updating a Databricks Repo to the latest code
    repo_path = "/Repos/user@domain.com/demo-repo"
    update_repo = DatabricksReposUpdateOperator(task_id="update_repo", repo_path=repo_path, branch="releases")