address comments

This commit is contained in:
Shreyas Goenka 2025-01-09 16:34:06 +05:30
parent 2a0dbdec3e
commit a2a3ae7154
No known key found for this signature in database
GPG Key ID: 92A07DF49CCB0622
2 changed files with 42 additions and 34 deletions

View File

@ -23,27 +23,31 @@ func TestBuiltInReader(t *testing.T) {
} }
for _, name := range exists { for _, name := range exists {
r := &builtinReader{name: name} t.Run(name, func(t *testing.T) {
fs, err := r.FS(context.Background()) r := &builtinReader{name: name}
assert.NoError(t, err) fs, err := r.FS(context.Background())
assert.NotNil(t, fs) assert.NoError(t, err)
assert.NotNil(t, fs)
// Assert file content returned is accurate and every template has a welcome // Assert file content returned is accurate and every template has a welcome
// message defined. // message defined.
fd, err := fs.Open("databricks_template_schema.json") fd, err := fs.Open("databricks_template_schema.json")
require.NoError(t, err) require.NoError(t, err)
b, err := io.ReadAll(fd) b, err := io.ReadAll(fd)
require.NoError(t, err) require.NoError(t, err)
assert.Contains(t, string(b), "welcome_message") assert.Contains(t, string(b), "welcome_message")
assert.NoError(t, fd.Close()) assert.NoError(t, fd.Close())
})
} }
r := &builtinReader{name: "doesnotexist"} t.Run("doesnotexist", func(t *testing.T) {
_, err := r.FS(context.Background()) r := &builtinReader{name: "doesnotexist"}
assert.EqualError(t, err, "builtin template doesnotexist not found") _, err := r.FS(context.Background())
assert.EqualError(t, err, "builtin template doesnotexist not found")
// Close should not error. // Close should not error.
assert.NoError(t, r.Close()) assert.NoError(t, r.Close())
})
} }
func TestGitUrlReader(t *testing.T) { func TestGitUrlReader(t *testing.T) {
@ -56,7 +60,7 @@ func TestGitUrlReader(t *testing.T) {
cloneFunc := func(ctx context.Context, url, reference, targetPath string) error { cloneFunc := func(ctx context.Context, url, reference, targetPath string) error {
numCalls++ numCalls++
args = []string{url, reference, targetPath} args = []string{url, reference, targetPath}
err := os.MkdirAll(filepath.Join(targetPath, "a/b/c"), 0o755) err := os.MkdirAll(filepath.Join(targetPath, "a", "b", "c"), 0o755)
require.NoError(t, err) require.NoError(t, err)
testutil.WriteFile(t, filepath.Join(targetPath, "a", "b", "c", "somefile"), "somecontent") testutil.WriteFile(t, filepath.Join(targetPath, "a", "b", "c", "somefile"), "somecontent")
return nil return nil

View File

@ -42,28 +42,32 @@ func TestTemplateResolverForDefaultTemplates(t *testing.T) {
"default-sql", "default-sql",
"dbt-sql", "dbt-sql",
} { } {
t.Run(name, func(t *testing.T) {
r := Resolver{
TemplatePathOrUrl: name,
}
tmpl, err := r.Resolve(context.Background())
require.NoError(t, err)
assert.Equal(t, &builtinReader{name: name}, tmpl.Reader)
assert.IsType(t, &writerWithFullTelemetry{}, tmpl.Writer)
})
}
t.Run("mlops-stacks", func(t *testing.T) {
r := Resolver{ r := Resolver{
TemplatePathOrUrl: name, TemplatePathOrUrl: "mlops-stacks",
ConfigFile: "/config/file",
} }
tmpl, err := r.Resolve(context.Background()) tmpl, err := r.Resolve(context.Background())
require.NoError(t, err) require.NoError(t, err)
assert.Equal(t, &builtinReader{name: name}, tmpl.Reader) // Assert reader and writer configuration
assert.IsType(t, &writerWithFullTelemetry{}, tmpl.Writer) assert.Equal(t, "https://github.com/databricks/mlops-stacks", tmpl.Reader.(*gitReader).gitUrl)
} assert.Equal(t, "/config/file", tmpl.Writer.(*writerWithFullTelemetry).configPath)
})
r := Resolver{
TemplatePathOrUrl: "mlops-stacks",
ConfigFile: "/config/file",
}
tmpl, err := r.Resolve(context.Background())
require.NoError(t, err)
// Assert reader and writer configuration
assert.Equal(t, "https://github.com/databricks/mlops-stacks", tmpl.Reader.(*gitReader).gitUrl)
assert.Equal(t, "/config/file", tmpl.Writer.(*writerWithFullTelemetry).configPath)
} }
func TestTemplateResolverForCustomUrl(t *testing.T) { func TestTemplateResolverForCustomUrl(t *testing.T) {