[Feature] Allow to filter jobs by name in databricks_jobs data source

docs/data-sources/jobs.md

@@ -16,6 +16,10 @@ Granting view [databricks_permissions](../resources/permissions.md) to all [data
 ```hcl
 data "databricks_jobs" "this" {}
 
+data "databricks_jobs" "tests" {
+  job_name_contains = "test"
+}
+
 resource "databricks_permissions" "everyone_can_view_all_jobs" {
   for_each = data.databricks_jobs.this.ids
   job_id   = each.value
@@ -38,6 +42,10 @@ output "x" {
 }
 ```
 
+## Argument Reference
+
+* `job_name_contains` - (Optional) Only return [databricks_job](../resources/job.md#) ids that match the given name string (case-insensitive).
+
 ## Attribute Reference
 
 This data source exports the following attributes:

jobs/data_jobs.go

@@ -3,29 +3,36 @@ package jobs
 import (
 	"context"
 	"fmt"
+	"strconv"
+	"strings"
 
+	"github.com/databricks/databricks-sdk-go"
+	"github.com/databricks/databricks-sdk-go/service/jobs"
 	"github.com/databricks/terraform-provider-databricks/common"
 )
 
 func DataSourceJobs() common.Resource {
-	type jobsData struct {
-		Ids map[string]string `json:"ids,omitempty" tf:"computed"`
-	}
-	return common.DataResource(jobsData{}, func(ctx context.Context, e any, c *common.DatabricksClient) error {
-		response := e.(*jobsData)
-		jobsAPI := NewJobsAPI(ctx, c)
-		list, err := jobsAPI.List()
-		if err != nil {
-			return err
-		}
-		response.Ids = map[string]string{}
-		for _, v := range list {
-			name := v.Settings.Name
-			_, duplicateName := response.Ids[name]
+	return common.WorkspaceData(func(ctx context.Context, data *struct {
+		Ids        map[string]string `json:"ids,omitempty" tf:"computed"`
+		NameFilter string            `json:"job_name_contains,omitempty"`
+	}, w *databricks.WorkspaceClient) error {
+		iter := w.Jobs.List(ctx, jobs.ListJobsRequest{ExpandTasks: false, Limit: 100})
+		data.Ids = map[string]string{}
+		nameFilter := strings.ToLower(data.NameFilter)
+		for iter.HasNext(ctx) {
+			job, err := iter.Next(ctx)
+			if err != nil {
+				return err
+			}
+			name := job.Settings.Name
+			if nameFilter != "" && !strings.Contains(strings.ToLower(name), nameFilter) {
+				continue
+			}
+			_, duplicateName := data.Ids[name]
 			if duplicateName {
 				return fmt.Errorf("duplicate job name detected: %s", name)
 			}
-			response.Ids[name] = v.ID()
+			data.Ids[name] = strconv.FormatInt(job.JobId, 10)
 		}
 		return nil
 	})

jobs/data_jobs_test.go

@@ -11,7 +11,7 @@ func TestJobsData(t *testing.T) {
 		Fixtures: []qa.HTTPFixture{
 			{
 				Method:   "GET",
-				Resource: "/api/2.1/jobs/list?expand_tasks=false&limit=25",
+				Resource: "/api/2.1/jobs/list?limit=100",
 				Response: JobListResponse{
 					Jobs: []Job{
 						{
@@ -41,3 +41,39 @@ func TestJobsData(t *testing.T) {
 		},
 	})
 }
+
+func TestJobsDataWithFilter(t *testing.T) {
+	qa.ResourceFixture{
+		Fixtures: []qa.HTTPFixture{
+			{
+				Method:   "GET",
+				Resource: "/api/2.1/jobs/list?limit=100",
+				Response: JobListResponse{
+					Jobs: []Job{
+						{
+							JobID: 123,
+							Settings: &JobSettings{
+								Name: "First",
+							},
+						},
+						{
+							JobID: 234,
+							Settings: &JobSettings{
+								Name: "Second",
+							},
+						},
+					},
+				},
+			},
+		},
+		Resource:    DataSourceJobs(),
+		Read:        true,
+		NonWritable: true,
+		ID:          "_",
+		HCL:         `job_name_contains = "Sec"`,
+	}.ApplyAndExpectData(t, map[string]any{
+		"ids": map[string]any{
+			"Second": "234",
+		},
+	})
+}

jobs/resource_job.go

@@ -677,8 +677,7 @@ func (a JobsAPI) ListByName(name string, expandTasks bool) ([]Job, error) {
 
 // List all jobs
 func (a JobsAPI) List() (l []Job, err error) {
-	l, err = a.ListByName("", false)
-	return
+	return a.ListByName("", false)
 }
 
 // RunsList returns a job runs list