Connect to Databricks to execute SQL queries against SQL warehouses, trigger and monitor job runs, manage clusters, and retrieve run outputs. Requires a Personal Access Token and workspace host URL.
Execute a SQL statement against a Databricks SQL warehouse and return results inline. Supports parameterized queries and Unity Catalog.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
warehouseId | string | Oui | The ID of the SQL warehouse to execute against |
statement | string | Oui | The SQL statement to execute (max 16 MiB) |
catalog | string | Non | Unity Catalog name (equivalent to USE CATALOG) |
schema | string | Non | Schema name (equivalent to USE SCHEMA) |
rowLimit | number | Non | Maximum number of rows to return |
waitTimeout | string | Non | How long to wait for results (e.g., "50s"). Range: "0s" or "5s" to "50s". Default: "50s" |
| Paramètre | Type | Description |
|---|
statementId | string | Unique identifier for the executed statement |
status | string | Execution status (SUCCEEDED, PENDING, RUNNING, FAILED, CANCELED, CLOSED) |
columns | array | Column schema of the result set |
↳ name | string | Column name |
↳ position | number | Column position (0-based) |
↳ typeName | string | Column type (STRING, INT, LONG, DOUBLE, BOOLEAN, TIMESTAMP, DATE, DECIMAL, etc.) |
data | array | Result rows as a 2D array of strings where each inner array is a row of column values |
totalRows | number | Total number of rows in the result |
truncated | boolean | Whether the result set was truncated due to row_limit or byte_limit |
Poll a SQL statement by its ID to retrieve status and results. Use this after Execute SQL when a query runs longer than the wait timeout.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
statementId | string | Oui | The ID of the statement to fetch (returned by Execute SQL) |
| Paramètre | Type | Description |
|---|
statementId | string | Unique identifier for the statement |
status | string | Execution status (SUCCEEDED, PENDING, RUNNING, FAILED, CANCELED, CLOSED) |
columns | array | Column schema of the result set |
↳ name | string | Column name |
↳ position | number | Column position (0-based) |
↳ typeName | string | Column type (STRING, INT, LONG, DOUBLE, BOOLEAN, TIMESTAMP, DATE, DECIMAL, etc.) |
data | array | Result rows as a 2D array of strings where each inner array is a row of column values |
totalRows | number | Total number of rows in the result |
truncated | boolean | Whether the result set was truncated due to row_limit or byte_limit |
List all SQL warehouses in a Databricks workspace including their size, state, and type. Use this to discover the warehouse ID needed for Execute SQL.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
| Paramètre | Type | Description |
|---|
warehouses | array | List of SQL warehouses in the workspace |
↳ warehouseId | string | Unique warehouse identifier |
↳ name | string | Warehouse display name |
↳ clusterSize | string | Warehouse size (e.g., 2X-Small, Small, Medium, Large) |
↳ state | string | Current state (STARTING, RUNNING, STOPPING, STOPPED, DELETING, DELETED) |
↳ warehouseType | string | Warehouse type (CLASSIC, PRO) |
↳ creatorName | string | Email of the warehouse creator |
↳ autoStopMinutes | number | Minutes of inactivity before auto-stop (0 = disabled) |
↳ numClusters | number | Current number of running clusters |
↳ minNumClusters | number | Minimum cluster count for scaling |
↳ maxNumClusters | number | Maximum cluster count for scaling |
↳ numActiveSessions | number | Number of active sessions |
↳ enableServerlessCompute | boolean | Whether serverless compute is enabled |
List all jobs in a Databricks workspace with optional filtering by name.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
limit | number | Non | Maximum number of jobs to return (range 1-100, default 20) |
offset | number | Non | Offset for pagination |
name | string | Non | Filter jobs by exact name (case-insensitive) |
expandTasks | boolean | Non | Include task and cluster details in the response (max 100 elements) |
| Paramètre | Type | Description |
|---|
jobs | array | List of jobs in the workspace |
↳ jobId | number | Unique job identifier |
↳ name | string | Job name |
↳ createdTime | number | Job creation timestamp (epoch ms) |
↳ creatorUserName | string | Email of the job creator |
↳ maxConcurrentRuns | number | Maximum number of concurrent runs |
↳ format | string | Job format (SINGLE_TASK or MULTI_TASK) |
hasMore | boolean | Whether more jobs are available for pagination |
nextPageToken | string | Token for fetching the next page of results |
Get the full definition and settings of a single Databricks job by its job ID.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
jobId | number | Oui | The canonical identifier of the job to retrieve |
| Paramètre | Type | Description |
|---|
jobId | number | The job ID |
name | string | Job name |
creatorUserName | string | Email of the job creator |
runAsUserName | string | User the job runs as |
createdTime | number | Job creation timestamp (epoch ms) |
format | string | Job format (SINGLE_TASK or MULTI_TASK) |
maxConcurrentRuns | number | Maximum number of concurrent runs |
timeoutSeconds | number | Job-level timeout in seconds (0 or null means no timeout) |
schedule | object | Cron schedule configuration (quartz_cron_expression, timezone_id, pause_status) |
tags | object | Key-value tags applied to the job |
tasks | array | Task definitions for the job (empty for single-task jobs) |
Trigger an existing Databricks job to run immediately with optional job-level or notebook parameters.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
jobId | number | Oui | The ID of the job to trigger |
jobParameters | string | Non | Job-level parameter overrides as a JSON object (e.g., {"key": "value"}) |
notebookParams | string | Non | Notebook task parameters as a JSON object (e.g., {"param1": "value1"}) |
idempotencyToken | string | Non | Idempotency token to prevent duplicate runs (max 64 characters) |
| Paramètre | Type | Description |
|---|
runId | number | The globally unique ID of the triggered run |
numberInJob | number | The sequence number of this run among all runs of the job |
Get the status, timing, and details of a Databricks job run by its run ID.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
runId | number | Oui | The canonical identifier of the run |
includeHistory | boolean | Non | Include repair history in the response |
includeResolvedValues | boolean | Non | Include resolved parameter values in the response |
| Paramètre | Type | Description |
|---|
runId | number | The run ID |
jobId | number | The job ID this run belongs to |
runName | string | Name of the run |
runType | string | Type of run (JOB_RUN, WORKFLOW_RUN, SUBMIT_RUN) |
attemptNumber | number | Retry attempt number (0 for initial attempt) |
state | object | Run state information |
↳ lifeCycleState | string | Lifecycle state (QUEUED, PENDING, RUNNING, TERMINATING, TERMINATED, SKIPPED, INTERNAL_ERROR, BLOCKED, WAITING_FOR_RETRY) |
↳ resultState | string | Result state (SUCCESS, FAILED, TIMEDOUT, CANCELED, SUCCESS_WITH_FAILURES, UPSTREAM_FAILED, UPSTREAM_CANCELED, EXCLUDED) |
↳ stateMessage | string | Descriptive message for the current state |
↳ userCancelledOrTimedout | boolean | Whether the run was cancelled by user or timed out |
startTime | number | Run start timestamp (epoch ms) |
endTime | number | Run end timestamp (epoch ms, 0 if still running) |
setupDuration | number | Cluster setup duration (ms) |
executionDuration | number | Execution duration (ms) |
cleanupDuration | number | Cleanup duration (ms) |
queueDuration | number | Time spent in queue before execution (ms) |
runPageUrl | string | URL to the run detail page in Databricks UI |
creatorUserName | string | Email of the user who triggered the run |
List job runs in a Databricks workspace with optional filtering by job, status, and time range.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
jobId | number | Non | Filter runs by job ID. Omit to list runs across all jobs |
activeOnly | boolean | Non | Only include active runs (PENDING, RUNNING, or TERMINATING) |
completedOnly | boolean | Non | Only include completed runs |
limit | number | Non | Maximum number of runs to return (range 1-24, default 20) |
offset | number | Non | Offset for pagination |
runType | string | Non | Filter by run type (JOB_RUN, WORKFLOW_RUN, SUBMIT_RUN) |
startTimeFrom | number | Non | Filter runs started at or after this timestamp (epoch ms) |
startTimeTo | number | Non | Filter runs started at or before this timestamp (epoch ms) |
| Paramètre | Type | Description |
|---|
runs | array | List of job runs |
↳ runId | number | Unique run identifier |
↳ jobId | number | Job this run belongs to |
↳ runName | string | Run name |
↳ runType | string | Run type (JOB_RUN, WORKFLOW_RUN, SUBMIT_RUN) |
↳ state | object | Run state information |
↳ lifeCycleState | string | Lifecycle state (QUEUED, PENDING, RUNNING, TERMINATING, TERMINATED, SKIPPED, INTERNAL_ERROR, BLOCKED, WAITING_FOR_RETRY) |
↳ resultState | string | Result state (SUCCESS, FAILED, TIMEDOUT, CANCELED, SUCCESS_WITH_FAILURES, UPSTREAM_FAILED, UPSTREAM_CANCELED, EXCLUDED) |
↳ stateMessage | string | Descriptive state message |
↳ userCancelledOrTimedout | boolean | Whether the run was cancelled by user or timed out |
↳ startTime | number | Run start timestamp (epoch ms) |
↳ endTime | number | Run end timestamp (epoch ms) |
hasMore | boolean | Whether more runs are available for pagination |
nextPageToken | string | Token for fetching the next page of results |
Cancel a running or pending Databricks job run. Cancellation is asynchronous; poll the run status to confirm termination.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
runId | number | Oui | The canonical identifier of the run to cancel |
| Paramètre | Type | Description |
|---|
success | boolean | Whether the cancel request was accepted |
Get the output of a completed Databricks job run, including notebook results, error messages, and logs. For multi-task jobs, use the task run ID (not the parent run ID).
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
runId | number | Oui | The run ID to get output for. For multi-task jobs, use the task run ID |
| Paramètre | Type | Description |
|---|
notebookOutput | object | Notebook task output (from dbutils.notebook.exit()) |
↳ result | string | Value passed to dbutils.notebook.exit() (max 5 MB) |
↳ truncated | boolean | Whether the result was truncated |
error | string | Error message if the run failed or output is unavailable |
errorTrace | string | Error stack trace if available |
logs | string | Log output (last 5 MB) from spark_jar, spark_python, or python_wheel tasks |
logsTruncated | boolean | Whether the log output was truncated |
List all clusters in a Databricks workspace including their state, configuration, and resource details.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
| Paramètre | Type | Description |
|---|
clusters | array | List of clusters in the workspace |
↳ clusterId | string | Unique cluster identifier |
↳ clusterName | string | Cluster display name |
↳ state | string | Current state (PENDING, RUNNING, RESTARTING, RESIZING, TERMINATING, TERMINATED, ERROR, UNKNOWN) |
↳ stateMessage | string | Human-readable state description |
↳ creatorUserName | string | Email of the cluster creator |
↳ sparkVersion | string | Spark runtime version (e.g., 13.3.x-scala2.12) |
↳ nodeTypeId | string | Worker node type identifier |
↳ driverNodeTypeId | string | Driver node type identifier |
↳ numWorkers | number | Number of worker nodes (for fixed-size clusters) |
↳ autoscale | object | Autoscaling configuration (null for fixed-size clusters) |
↳ minWorkers | number | Minimum number of workers |
↳ maxWorkers | number | Maximum number of workers |
↳ clusterSource | string | Origin (API, UI, JOB, MODELS, PIPELINE, PIPELINE_MAINTENANCE, SQL) |
↳ autoterminationMinutes | number | Minutes of inactivity before auto-termination (0 = disabled) |
↳ startTime | number | Cluster start timestamp (epoch ms) |
Get the state, configuration, and resource details of a single Databricks cluster by its cluster ID.
| Paramètre | Type | Obligatoire | Description |
|---|
host | string | Oui | Databricks workspace host (e.g., dbc-abc123.cloud.databricks.com) |
apiKey | string | Oui | Databricks Personal Access Token |
clusterId | string | Oui | The ID of the cluster to retrieve |
| Paramètre | Type | Description |
|---|
cluster | object | Cluster detail |
↳ clusterId | string | Unique cluster identifier |
↳ clusterName | string | Cluster display name |
↳ state | string | Current state (PENDING, RUNNING, RESTARTING, RESIZING, TERMINATING, TERMINATED, ERROR, UNKNOWN) |
↳ stateMessage | string | Human-readable state description |
↳ creatorUserName | string | Email of the cluster creator |
↳ sparkVersion | string | Spark runtime version (e.g., 13.3.x-scala2.12) |
↳ nodeTypeId | string | Worker node type identifier |
↳ driverNodeTypeId | string | Driver node type identifier |
↳ numWorkers | number | Number of worker nodes (for fixed-size clusters) |
↳ autoscale | object | Autoscaling configuration (null for fixed-size clusters) |
↳ minWorkers | number | Minimum number of workers |
↳ maxWorkers | number | Maximum number of workers |
↳ clusterSource | string | Origin (API, UI, JOB, MODELS, PIPELINE, PIPELINE_MAINTENANCE, SQL) |
↳ autoterminationMinutes | number | Minutes of inactivity before auto-termination (0 = disabled) |
↳ startTime | number | Cluster start timestamp (epoch ms) |
