package resources import ( "context" "fmt" "github.com/databricks/cli/bundle/config/paths" "github.com/databricks/cli/libs/log" "github.com/databricks/databricks-sdk-go" "github.com/databricks/databricks-sdk-go/marshal" "github.com/databricks/databricks-sdk-go/service/pipelines" ) type Pipeline struct { ID string `json:"id,omitempty" bundle:"readonly"` Permissions []Permission `json:"permissions,omitempty"` ModifiedStatus ModifiedStatus `json:"modified_status,omitempty" bundle:"internal"` paths.Paths *pipelines.PipelineSpec } func (s *Pipeline) UnmarshalJSON(b []byte) error { return marshal.Unmarshal(b, s) } func (s Pipeline) MarshalJSON() ([]byte, error) { return marshal.Marshal(s) } func (p *Pipeline) Exists(ctx context.Context, w *databricks.WorkspaceClient, id string) (bool, error) { _, err := w.Pipelines.Get(ctx, pipelines.GetPipelineRequest{ PipelineId: id, }) if err != nil { log.Debugf(ctx, "pipeline %s does not exist", id) return false, err } return true, nil } func (p *Pipeline) TerraformResourceName() string { return "databricks_pipeline" } func (p *Pipeline) Validate() error { if p == nil || !p.DynamicValue.IsValid() { return fmt.Errorf("pipeline is not defined") } return nil }