mirror of https://github.com/databricks/cli.git
56 lines
1.4 KiB
Go
56 lines
1.4 KiB
Go
|
package tfdyn
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"fmt"
|
||
|
|
|
||
|
|
"github.com/databricks/cli/bundle/internal/tf/schema"
|
||
|
|
"github.com/databricks/cli/libs/dyn"
|
||
|
|
"github.com/databricks/cli/libs/dyn/convert"
|
||
|
|
"github.com/databricks/cli/libs/log"
|
||
|
|
)
|
||
|
|
|
||
|
|
func convertPipelineResource(ctx context.Context, vin dyn.Value) (dyn.Value, error) {
|
||
|
|
// Modify top-level keys.
|
||
|
|
vout, err := renameKeys(vin, map[string]string{
|
||
|
|
"libraries": "library",
|
||
|
|
"clusters": "cluster",
|
||
|
|
"notifications": "notification",
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
return dyn.InvalidValue, err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Normalize the output value to the target schema.
|
||
|
|
vout, diags := convert.Normalize(schema.ResourcePipeline{}, vout)
|
||
|
|
for _, diag := range diags {
|
||
|
|
log.Debugf(ctx, "pipeline normalization diagnostic: %s", diag.Summary)
|
||
|
|
}
|
||
|
|
|
||
|
|
return vout, err
|
||
|
|
}
|
||
|
|
|
||
|
|
type pipelineConverter struct{}
|
||
|
|
|
||
|
|
func (pipelineConverter) Convert(ctx context.Context, key string, vin dyn.Value, out *schema.Resources) error {
|
||
|
|
vout, err := convertPipelineResource(ctx, vin)
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Add the converted resource to the output.
|
||
|
|
out.Pipeline[key] = vout.AsAny()
|
||
|
|
|
||
|
|
// Configure permissions for this resource.
|
||
|
|
if permissions := convertPermissionsResource(ctx, vin); permissions != nil {
|
||
|
|
permissions.PipelineId = fmt.Sprintf("${databricks_pipeline.%s.id}", key)
|
||
|
|
out.Permissions["pipeline_"+key] = permissions
|
||
|
|
}
|
||
|
|
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func init() {
|
||
|
|
registerConverter("pipelines", pipelineConverter{})
|
||
|
|
}
|