mirror of https://github.com/databricks/cli.git
30 lines
978 B
Go
30 lines
978 B
Go
|
package config_tests
|
||
|
|
|
||
|
|
import (
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
"github.com/stretchr/testify/assert"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestOverridePipelineClusterDev(t *testing.T) {
|
||
|
|
b := loadTarget(t, "./override_pipeline_cluster", "development")
|
||
|
|
assert.Equal(t, "job", b.Config.Resources.Pipelines["foo"].Name)
|
||
|
|
assert.Len(t, b.Config.Resources.Pipelines["foo"].Clusters, 1)
|
||
|
|
|
||
|
|
c := b.Config.Resources.Pipelines["foo"].Clusters[0]
|
||
|
|
assert.Equal(t, map[string]string{"foo": "bar"}, c.SparkConf)
|
||
|
|
assert.Equal(t, "i3.xlarge", c.NodeTypeId)
|
||
|
|
assert.Equal(t, 1, c.NumWorkers)
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestOverridePipelineClusterStaging(t *testing.T) {
|
||
|
|
b := loadTarget(t, "./override_pipeline_cluster", "staging")
|
||
|
|
assert.Equal(t, "job", b.Config.Resources.Pipelines["foo"].Name)
|
||
|
|
assert.Len(t, b.Config.Resources.Pipelines["foo"].Clusters, 1)
|
||
|
|
|
||
|
|
c := b.Config.Resources.Pipelines["foo"].Clusters[0]
|
||
|
|
assert.Equal(t, map[string]string{"foo": "bar"}, c.SparkConf)
|
||
|
|
assert.Equal(t, "i3.2xlarge", c.NodeTypeId)
|
||
|
|
assert.Equal(t, 4, c.NumWorkers)
|
||
|
|
}
|