mirror of https://github.com/databricks/cli.git
Enable 'govet' linter
This commit is contained in:
parent
2ee7d56ae6
commit
caeb8045cc
|
@ -4,7 +4,7 @@ linters:
|
||||||
- bodyclose
|
- bodyclose
|
||||||
- errcheck
|
- errcheck
|
||||||
- gosimple
|
- gosimple
|
||||||
#- govet
|
- govet
|
||||||
- ineffassign
|
- ineffassign
|
||||||
- staticcheck
|
- staticcheck
|
||||||
- unused
|
- unused
|
||||||
|
|
|
@ -42,7 +42,7 @@ func (m *detectPkg) Apply(ctx context.Context, b *bundle.Bundle) diag.Diagnostic
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Infof(ctx, fmt.Sprintf("Found Python wheel project at %s", b.BundleRootPath))
|
log.Infof(ctx, "Found Python wheel project at %s", b.BundleRootPath)
|
||||||
module := extractModuleName(setupPy)
|
module := extractModuleName(setupPy)
|
||||||
|
|
||||||
if b.Config.Artifacts == nil {
|
if b.Config.Artifacts == nil {
|
||||||
|
|
|
@ -19,7 +19,7 @@ func (t *mutatorWithError) Name() string {
|
||||||
|
|
||||||
func (t *mutatorWithError) Apply(_ context.Context, b *Bundle) diag.Diagnostics {
|
func (t *mutatorWithError) Apply(_ context.Context, b *Bundle) diag.Diagnostics {
|
||||||
t.applyCalled++
|
t.applyCalled++
|
||||||
return diag.Errorf(t.errorMsg)
|
return diag.Errorf("%s", t.errorMsg)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestDeferredMutatorWhenAllMutatorsSucceed(t *testing.T) {
|
func TestDeferredMutatorWhenAllMutatorsSucceed(t *testing.T) {
|
||||||
|
|
|
@ -2,7 +2,6 @@ package terraform
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
"github.com/databricks/cli/bundle"
|
"github.com/databricks/cli/bundle"
|
||||||
|
@ -57,7 +56,7 @@ func (p *plan) Apply(ctx context.Context, b *bundle.Bundle) diag.Diagnostics {
|
||||||
IsEmpty: !notEmpty,
|
IsEmpty: !notEmpty,
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Debugf(ctx, fmt.Sprintf("Planning complete and persisted at %s\n", planPath))
|
log.Debugf(ctx, "Planning complete and persisted at %s\n", planPath)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -173,7 +173,7 @@ func TestFilerForVolumeNotFoundAndInBundle(t *testing.T) {
|
||||||
{
|
{
|
||||||
Severity: diag.Error,
|
Severity: diag.Error,
|
||||||
Summary: "volume /Volumes/main/my_schema/my_volume does not exist: error from API",
|
Summary: "volume /Volumes/main/my_schema/my_volume does not exist: error from API",
|
||||||
Locations: []dyn.Location{{"config.yml", 1, 2}, {"volume.yml", 1, 2}},
|
Locations: []dyn.Location{{File: "config.yml", Line: 1, Column: 2}, {File: "volume.yml", Line: 1, Column: 2}},
|
||||||
Paths: []dyn.Path{dyn.MustPathFromString("workspace.artifact_path"), dyn.MustPathFromString("resources.volumes.foo")},
|
Paths: []dyn.Path{dyn.MustPathFromString("workspace.artifact_path"), dyn.MustPathFromString("resources.volumes.foo")},
|
||||||
Detail: `You are using a volume in your artifact_path that is managed by
|
Detail: `You are using a volume in your artifact_path that is managed by
|
||||||
this bundle but which has not been deployed yet. Please first deploy
|
this bundle but which has not been deployed yet. Please first deploy
|
||||||
|
|
|
@ -143,7 +143,7 @@ func logProgressCallback(ctx context.Context, progressLogger *cmdio.Logger) func
|
||||||
progressLogger.Log(event)
|
progressLogger.Log(event)
|
||||||
|
|
||||||
// log progress events in using the default logger
|
// log progress events in using the default logger
|
||||||
log.Infof(ctx, event.String())
|
log.Infof(ctx, "%s", event.String())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -37,7 +37,7 @@ func (r *pipelineRunner) logEvent(ctx context.Context, event pipelines.PipelineE
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if logString != "" {
|
if logString != "" {
|
||||||
log.Errorf(ctx, fmt.Sprintf("[%s] %s", event.EventType, logString))
|
log.Errorf(ctx, "[%s] %s", event.EventType, logString)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -132,7 +132,7 @@ func (r *pipelineRunner) Run(ctx context.Context, opts *Options) (output.RunOutp
|
||||||
}
|
}
|
||||||
for _, event := range events {
|
for _, event := range events {
|
||||||
progressLogger.Log(&event)
|
progressLogger.Log(&event)
|
||||||
log.Infof(ctx, event.String())
|
log.Infof(ctx, "%s", event.String())
|
||||||
}
|
}
|
||||||
|
|
||||||
update, err := w.Pipelines.GetUpdateByPipelineIdAndUpdateId(ctx, pipelineID, updateID)
|
update, err := w.Pipelines.GetUpdateByPipelineIdAndUpdateId(ctx, pipelineID, updateID)
|
||||||
|
|
|
@ -15,7 +15,8 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestEmptyHttpRequest(t *testing.T) {
|
func TestEmptyHttpRequest(t *testing.T) {
|
||||||
ctx, _ := context.WithCancel(context.Background())
|
ctx, cancel := context.WithCancel(context.Background())
|
||||||
|
defer cancel()
|
||||||
req := emptyHttpRequest(ctx)
|
req := emptyHttpRequest(ctx)
|
||||||
assert.Equal(t, req.Context(), ctx)
|
assert.Equal(t, req.Context(), ctx)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue