databricks.getJob

Explore with Pulumi AI

Databricks v1.56.0 published on Tuesday, Nov 12, 2024 by Pulumi

pulumi/pulumi-databricks

Example Usage

Getting the existing cluster id of specific databricks.Job by name or by id:

import * as pulumi from "@pulumi/pulumi";
import * as databricks from "@pulumi/databricks";

const this = databricks.getJob({
    jobName: "My job",
});
export const jobNumWorkers = _this.then(_this => _this.jobSettings?.settings?.newCluster?.numWorkers);

import pulumi
import pulumi_databricks as databricks

this = databricks.get_job(job_name="My job")
pulumi.export("jobNumWorkers", this.job_settings.settings.new_cluster.num_workers)

package main

import (
	"github.com/pulumi/pulumi-databricks/sdk/go/databricks"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		this, err := databricks.LookupJob(ctx, &databricks.LookupJobArgs{
			JobName: pulumi.StringRef("My job"),
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("jobNumWorkers", this.JobSettings.Settings.NewCluster.NumWorkers)
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Databricks = Pulumi.Databricks;

return await Deployment.RunAsync(() => 
{
    var @this = Databricks.GetJob.Invoke(new()
    {
        JobName = "My job",
    });

    return new Dictionary<string, object?>
    {
        ["jobNumWorkers"] = @this.Apply(@this => @this.Apply(getJobResult => getJobResult.JobSettings?.Settings?.NewCluster?.NumWorkers)),
    };
});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.databricks.DatabricksFunctions;
import com.pulumi.databricks.inputs.GetJobArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var this = DatabricksFunctions.getJob(GetJobArgs.builder()
            .jobName("My job")
            .build());

        ctx.export("jobNumWorkers", this_.jobSettings().settings().newCluster().numWorkers());
    }
}

variables:
  this:
    fn::invoke:
      Function: databricks:getJob
      Arguments:
        jobName: My job
outputs:
  jobNumWorkers: ${this.jobSettings.settings.newCluster.numWorkers}

The following resources are used in the same context:

databricks.getJobs data to get all jobs and their names from a workspace.
databricks.Job to manage Databricks Jobs to run non-interactive code in a databricks_cluster.

Using getJob

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

function getJob(args: GetJobArgs, opts?: InvokeOptions): Promise<GetJobResult>
function getJobOutput(args: GetJobOutputArgs, opts?: InvokeOptions): Output<GetJobResult>

def get_job(id: Optional[str] = None,
            job_id: Optional[str] = None,
            job_name: Optional[str] = None,
            job_settings: Optional[GetJobJobSettings] = None,
            name: Optional[str] = None,
            opts: Optional[InvokeOptions] = None) -> GetJobResult
def get_job_output(id: Optional[pulumi.Input[str]] = None,
            job_id: Optional[pulumi.Input[str]] = None,
            job_name: Optional[pulumi.Input[str]] = None,
            job_settings: Optional[pulumi.Input[GetJobJobSettingsArgs]] = None,
            name: Optional[pulumi.Input[str]] = None,
            opts: Optional[InvokeOptions] = None) -> Output[GetJobResult]

func LookupJob(ctx *Context, args *LookupJobArgs, opts ...InvokeOption) (*LookupJobResult, error)
func LookupJobOutput(ctx *Context, args *LookupJobOutputArgs, opts ...InvokeOption) LookupJobResultOutput

> Note: This function is named LookupJob in the Go SDK.

public static class GetJob 
{
    public static Task<GetJobResult> InvokeAsync(GetJobArgs args, InvokeOptions? opts = null)
    public static Output<GetJobResult> Invoke(GetJobInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetJobResult> getJob(GetJobArgs args, InvokeOptions options)
// Output-based functions aren't available in Java yet

fn::invoke:
  function: databricks:index/getJob:getJob
  arguments:
    # arguments dictionary

The following arguments are supported:

Id string: the id of databricks.Job if the resource was matched by name.
JobId string
JobName string
JobSettings GetJobJobSettings: the same fields as in databricks_job.
Name string: the job name of databricks.Job if the resource was matched by id.

Id string: the id of databricks.Job if the resource was matched by name.
JobId string
JobName string
JobSettings GetJobJobSettings: the same fields as in databricks_job.
Name string: the job name of databricks.Job if the resource was matched by id.

id String: the id of databricks.Job if the resource was matched by name.
jobId String
jobName String
jobSettings GetJobJobSettings: the same fields as in databricks_job.
name String: the job name of databricks.Job if the resource was matched by id.

id string: the id of databricks.Job if the resource was matched by name.
jobId string
jobName string
jobSettings GetJobJobSettings: the same fields as in databricks_job.
name string: the job name of databricks.Job if the resource was matched by id.

id str: the id of databricks.Job if the resource was matched by name.
job_id str
job_name str
job_settings GetJobJobSettings: the same fields as in databricks_job.
name str: the job name of databricks.Job if the resource was matched by id.

id String: the id of databricks.Job if the resource was matched by name.
jobId String
jobName String
jobSettings Property Map: the same fields as in databricks_job.
name String: the job name of databricks.Job if the resource was matched by id.

getJob Result

The following output properties are available:

Id string: the id of databricks.Job if the resource was matched by name.
JobId string
JobName string
JobSettings GetJobJobSettings: the same fields as in databricks_job.
Name string: the job name of databricks.Job if the resource was matched by id.

Id string: the id of databricks.Job if the resource was matched by name.
JobId string
JobName string
JobSettings GetJobJobSettings: the same fields as in databricks_job.
Name string: the job name of databricks.Job if the resource was matched by id.

id String: the id of databricks.Job if the resource was matched by name.
jobId String
jobName String
jobSettings GetJobJobSettings: the same fields as in databricks_job.
name String: the job name of databricks.Job if the resource was matched by id.

id string: the id of databricks.Job if the resource was matched by name.
jobId string
jobName string
jobSettings GetJobJobSettings: the same fields as in databricks_job.
name string: the job name of databricks.Job if the resource was matched by id.

id str: the id of databricks.Job if the resource was matched by name.
job_id str
job_name str
job_settings GetJobJobSettings: the same fields as in databricks_job.
name str: the job name of databricks.Job if the resource was matched by id.

id String: the id of databricks.Job if the resource was matched by name.
jobId String
jobName String
jobSettings Property Map: the same fields as in databricks_job.
name String: the job name of databricks.Job if the resource was matched by id.