Prefect Collection for interacting with Databricks: prefect-databricks

[anna_geller]

Docs

https://prefecthq.github.io/prefect-databricks/

---

Code

GitHub - PrefectHQ/prefect-databricks: Prefect integrations for interacting...

Examples

from prefect import flow
from prefect_databricks import DatabricksCredentials
from prefect_databricks.jobs import jobs_list


@flow
def example_execute_endpoint_flow():
    databricks_credentials = DatabricksCredentials.load("my-block")
    jobs = jobs_list(
        databricks_credentials,
        limit=5
    )
    return jobs

example_execute_endpoint_flow()