steve/databricks-cli
steve
/
databricks-cli
mirror of https://github.com/databricks/cli.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Cleanup

This commit is contained in:
Lennart Kats 2023-07-07 11:09:09 +02:00
parent d221d4d348
commit 50b76bb41e
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bundle/config/mutator/populate_current_user.go
View File

@ -18,10 +18,6 @@ func (m *populateCurrentUser) Name() string {
} }
func (m *populateCurrentUser) Apply(ctx context.Context, b *bundle.Bundle) error { func (m *populateCurrentUser) Apply(ctx context.Context, b *bundle.Bundle) error {
if b.Config.Workspace.CurrentUser != nil {
return nil
}
w := b.WorkspaceClient() w := b.WorkspaceClient()
me, err := w.CurrentUser.Me(ctx) me, err := w.CurrentUser.Me(ctx)
if err != nil { if err != nil {

4
bundle/config/mutator/process_environment_mode.go
View File

@ -11,7 +11,7 @@ import (
type processEnvironmentMode struct{} type processEnvironmentMode struct{}
const debugConcurrentRuns = 4 const developmentConcurrentRuns = 4
func ProcessEnvironmentMode() bundle.Mutator { func ProcessEnvironmentMode() bundle.Mutator {
return &processEnvironmentMode{} return &processEnvironmentMode{}
@ -34,7 +34,7 @@ func processDevelopmentMode(b *bundle.Bundle) error {
} }
r.Jobs[i].Tags["dev"] = "" r.Jobs[i].Tags["dev"] = ""
if r.Jobs[i].MaxConcurrentRuns == 0 { if r.Jobs[i].MaxConcurrentRuns == 0 {
r.Jobs[i].MaxConcurrentRuns = debugConcurrentRuns r.Jobs[i].MaxConcurrentRuns = developmentConcurrentRuns
} }
if r.Jobs[i].Schedule != nil { if r.Jobs[i].Schedule != nil {
r.Jobs[i].Schedule.PauseStatus = "PAUSED" r.Jobs[i].Schedule.PauseStatus = "PAUSED"