Skip to main content

Run a workflow

This recipe triggers a Databricks Workflows job using the Databricks SDK for Python.

Code snippet

app.py
import streamlit as st
from databricks.sdk import WorkspaceClient

w = WorkspaceClient()

job_id = st.text_input(
label="Specify job id:",
placeholder="921773893211960",
help="You can find the job ID under job details after opening a job in the UI.",
)

parameters_input = st.text_area(
label="Specify job parameters as JSON:",
placeholder='{"param1": "value1", "param2": "value2"}',
)

parameters = eval(parameters_input.strip())

if st.button(label="Trigger job"):
try:
run = w.jobs.run_now(job_id=job_id, job_parameters=parameters)
st.text(f"Started run with ID {run.run_id}")
except Exception as e:
st.warning(e)

Resources

Permissions

Your app service principal needs the following permissions:

  • CAN MANAGE RUN permission on the job

See Control access to a job for more information.

Dependencies

requirements.txt
databricks-sdk
streamlit