Databricks (Service Principal) ACTION
Create Job
- Action
- Writes data
- OAuth
- SDK
- MCP
IMPLEMENTATION
Call this tool
Connect a user's Databricks (Service Principal) account once, then configure and run Create Job from your backend or agent.
import { PipedreamClient } from "@pipedream/sdk"
const pd = new PipedreamClient({
projectId: process.env.PIPEDREAM_PROJECT_ID!,
clientId: process.env.PIPEDREAM_CLIENT_ID!,
clientSecret: process.env.PIPEDREAM_CLIENT_SECRET!,
projectEnvironment: "production",
})
const result = await pd.actions.run({
id: "databricks_oauth-create-job",
externalUserId: "{external_user_id}", // any stable ID for this user in your system
configuredProps: {
databricks_oauth: { authProvisionId: "apn_xxxxxxx" },
tasks: ["Tasks"],
name: "Job Name",
},
})
console.log(result)curl -X POST https://api.pipedream.com/v1/connect/{project_id}/actions/run \
-H "Content-Type: application/json" \
-H "X-PD-Environment: production" \
-H "Authorization: Bearer {access_token}" \
-d '{
"external_user_id": "{external_user_id}",
"id": "databricks_oauth-create-job",
"configured_props": {
"databricks_oauth": { "authProvisionId": "apn_xxxxxxx" },
"tasks": ["Tasks"],
"name": "Job Name"
}
}'// accessToken: mint a short-lived token with the Connect SDK — see the MCP guide
const transport = new StreamableHTTPClientTransport(
new URL("https://remote.mcp.pipedream.net/v3"),
{
requestInit: {
headers: {
Authorization: `Bearer ${accessToken}`,
"x-pd-project-id": "{project_id}",
"x-pd-environment": "production",
"x-pd-external-user-id": "{external_user_id}", // any stable ID for this user in your system
"x-pd-app-slug": "databricks_oauth",
},
},
},
)
const mcp = new Client({ name: "my-agent", version: "1.0.0" })
await mcp.connect(transport)
const { tools } = await mcp.listTools()
// listTools() hands your model this tool's input schema, so it can
// fill the arguments itself:
const result = await mcp.callTool({
name: "databricks_oauth-create-job",
arguments: {
tasks: ["Tasks"],
name: "Job Name",
},
})SCHEMA
Inputs
Pipedream supplies the connected account. Your application provides the operation-specific values below. Dynamic inputs are resolved against that user's account.
| Property | Type | Description |
|---|---|---|
tasks Tasks | string[] | A list of task specifications to be executed by this job. JSON string format. See the API documentation for task specification details. Example: Required |
name Job Name | string | An optional name for the job Optional |
tags Tags | object | A map of tags associated with the job. These are forwarded to the cluster as cluster tags for jobs clusters, and are subject to the same limitations as cluster tags Optional |
jobClusters Job Clusters | string[] | A list of job cluster specifications that can be shared and reused by tasks of this job. JSON string format. See the API documentation for job cluster specification details. Example: Optional |
emailNotifications Email Notifications | string | An optional set of email addresses to notify when runs of this job begin, complete, or when the job is deleted. Specify as a JSON object with keys for each notification type. See the API documentation for details on each field. Example: Optional |
webhookNotifications Webhook Notifications | string | A collection of system notification IDs to notify when runs of this job begin, complete, or encounter specific events. Specify as a JSON object with keys for each notification type. Each key accepts an array of objects with an Supported keys:
See the API documentation for details. Example: Optional |
timeoutSeconds Timeout Seconds | integer | An optional timeout applied to each run of this job. The default behavior is to have no timeout Optional |
schedule Schedule | string | An optional periodic schedule for this job, specified as a JSON object. By default, the job only runs when triggered manually or via the API. The schedule object must include:
Example: Optional |
maxConcurrentRuns Max Concurrent Runs | integer | An optional maximum allowed number of concurrent runs of the job. Defaults to 1 Optional |
gitSource Git Source | string | An optional specification for a remote Git repository containing the source code used by tasks. Provide as a JSON string. This enables version-controlled source code for notebook, dbt, Python script, and SQL File tasks. If Fields:
Example: Optional |
accessControlList Access Control List | string[] | A list of permissions to set on the job, specified as a JSON array of objects. Each object can define permissions for a user, group, or service principal. Each object may include:
Example:
See the API documentation for more details. Optional |
REFERENCE
Tool details
Behavior hints are published with the component in the Pipedream registry and surface as MCP tool annotations, so an agent can reason about a tool before it calls it.
- Registry key
- databricks_oauth-create-job
- Version
- 0.0.1
- App
- Databricks (Service Principal)
- Authentication
- OAuth
- Read-only
- No
- Destructive
- No
- Open world
- Yes
- Source
- View on GitHub ↗