diff --git a/brickflow_plugins/databricks/run_job.py b/brickflow_plugins/databricks/run_job.py index 22c57df..c45d4e3 100644 --- a/brickflow_plugins/databricks/run_job.py +++ b/brickflow_plugins/databricks/run_job.py @@ -50,5 +50,6 @@ def execute(self): job_name=self.job_name, ) # TODO: add support for passing parameters to the remote job + # TODO: wait for the job to finish run = self._workspace_obj.jobs.run_now(job_id) ctx.log.info("Job run status: %s", run.response)