Skip to content

Commit b83a8c0

Browse files
authored
Add condition_task (private preview) (#2459)
Add condition_task (private preview) * Add condition_task * Remove TaskDependency since it isn't needed anymore
1 parent e1ffaa0 commit b83a8c0

File tree

1 file changed

+22
-20
lines changed

1 file changed

+22
-20
lines changed

jobs/resource_job.go

Lines changed: 22 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ import (
44
"context"
55
"errors"
66
"fmt"
7+
"github.com/databricks/databricks-sdk-go/service/jobs"
78
"log"
89
"sort"
910
"strconv"
@@ -146,10 +147,6 @@ type CronSchedule struct {
146147
PauseStatus string `json:"pause_status,omitempty" tf:"computed"`
147148
}
148149

149-
type TaskDependency struct {
150-
TaskKey string `json:"task_key,omitempty"`
151-
}
152-
153150
// BEGIN Jobs + Repo integration preview
154151
type GitSource struct {
155152
Url string `json:"git_url" tf:"alias:url"`
@@ -162,27 +159,32 @@ type GitSource struct {
162159
// End Jobs + Repo integration preview
163160

164161
type JobTaskSettings struct {
165-
TaskKey string `json:"task_key,omitempty"`
166-
Description string `json:"description,omitempty"`
167-
DependsOn []TaskDependency `json:"depends_on,omitempty"`
162+
TaskKey string `json:"task_key,omitempty"`
163+
Description string `json:"description,omitempty"`
164+
DependsOn []jobs.TaskDependency `json:"depends_on,omitempty"`
168165

169166
// BEGIN Jobs + RunIf preview
170167
RunIf string `json:"run_if,omitempty" tf:"suppress_diff"`
171168
// END Jobs + RunIf preview
172169

173-
ExistingClusterID string `json:"existing_cluster_id,omitempty" tf:"group:cluster_type"`
174-
NewCluster *clusters.Cluster `json:"new_cluster,omitempty" tf:"group:cluster_type"`
175-
JobClusterKey string `json:"job_cluster_key,omitempty" tf:"group:cluster_type"`
176-
ComputeKey string `json:"compute_key,omitempty" tf:"group:cluster_type"`
177-
Libraries []libraries.Library `json:"libraries,omitempty" tf:"slice_set,alias:library"`
178-
NotebookTask *NotebookTask `json:"notebook_task,omitempty" tf:"group:task_type"`
179-
SparkJarTask *SparkJarTask `json:"spark_jar_task,omitempty" tf:"group:task_type"`
180-
SparkPythonTask *SparkPythonTask `json:"spark_python_task,omitempty" tf:"group:task_type"`
181-
SparkSubmitTask *SparkSubmitTask `json:"spark_submit_task,omitempty" tf:"group:task_type"`
182-
PipelineTask *PipelineTask `json:"pipeline_task,omitempty" tf:"group:task_type"`
183-
PythonWheelTask *PythonWheelTask `json:"python_wheel_task,omitempty" tf:"group:task_type"`
184-
SqlTask *SqlTask `json:"sql_task,omitempty" tf:"group:task_type"`
185-
DbtTask *DbtTask `json:"dbt_task,omitempty" tf:"group:task_type"`
170+
ExistingClusterID string `json:"existing_cluster_id,omitempty" tf:"group:cluster_type"`
171+
NewCluster *clusters.Cluster `json:"new_cluster,omitempty" tf:"group:cluster_type"`
172+
JobClusterKey string `json:"job_cluster_key,omitempty" tf:"group:cluster_type"`
173+
ComputeKey string `json:"compute_key,omitempty" tf:"group:cluster_type"`
174+
Libraries []libraries.Library `json:"libraries,omitempty" tf:"slice_set,alias:library"`
175+
176+
NotebookTask *NotebookTask `json:"notebook_task,omitempty" tf:"group:task_type"`
177+
SparkJarTask *SparkJarTask `json:"spark_jar_task,omitempty" tf:"group:task_type"`
178+
SparkPythonTask *SparkPythonTask `json:"spark_python_task,omitempty" tf:"group:task_type"`
179+
SparkSubmitTask *SparkSubmitTask `json:"spark_submit_task,omitempty" tf:"group:task_type"`
180+
PipelineTask *PipelineTask `json:"pipeline_task,omitempty" tf:"group:task_type"`
181+
PythonWheelTask *PythonWheelTask `json:"python_wheel_task,omitempty" tf:"group:task_type"`
182+
SqlTask *SqlTask `json:"sql_task,omitempty" tf:"group:task_type"`
183+
DbtTask *DbtTask `json:"dbt_task,omitempty" tf:"group:task_type"`
184+
185+
// ConditionTask is in private preview
186+
ConditionTask *jobs.ConditionTask `json:"condition_task,omitempty" tf:"group:task_type"`
187+
186188
EmailNotifications *EmailNotifications `json:"email_notifications,omitempty" tf:"suppress_diff"`
187189
TimeoutSeconds int32 `json:"timeout_seconds,omitempty"`
188190
MaxRetries int32 `json:"max_retries,omitempty"`

0 commit comments

Comments
 (0)