Hi team,
We are trying to submit and run the jobs using the below flow
from prefect import flow
from prefect_databricks import DatabricksCredentials
from prefect_databricks.flows import (
jobs_runs_submit_by_id_and_wait_for_completion,
)
@flow
def existing_job_submit(job_id):
databricks_credentials = DatabricksCredentials.load("poc")
run = jobs_runs_submit_by_id_and_wait_for_completion(
databricks_credentials=databricks_credentials, job_id=job_id
)
return run
if
name == "__main__":
existing_job_submit(job_id="xxxx")
and getting the following error
https://github.com/PrefectHQ/prefect-databricks/issues/64
any solution/suggestions to fix this error?