dbx-dash

┌─ dbx-dash v0.2.0 ──────────────────────────────────────── 14:23:01 ─┐
│ Workspace: ◀ production ▶ ⟳ refreshing... │
├───────────────────────────────────────────────────────────────────────┤
│ production │
│ ┌─Running Jobs──┐ ┌─Failed Jobs───┐ ┌─Active Clusters─┐ │
│ │ 3 │ │ 1 │ │ 4 │ │
│ └───────────────┘ └───────────────┘ └─────────────────┘ │
│ │
│ staging │
│ ┌─Running Jobs──┐ ┌─Failed Jobs───┐ ┌─Active Clusters─┐ │
│ │ 0 │ │ 0 │ │ 1 │ │
│ └───────────────┘ └───────────────┘ └─────────────────┘ │
├───────────────────────────────────────────────────────────────────────┤
│ 1 Dashboard 2 Jobs 3 Clusters 4 Warehouses r Refresh q Quit │
└───────────────────────────────────────────────────────────────────────┘

Features

Install

go install github.com/tttao/dbx-dash/cmd/dbx-dash@latest

git clone https://github.com/tttao/dbx-dash
cd dbx-dash
go build -o dbx-dash ./cmd/dbx-dash

Usage

# Launch dashboard (reads all profiles from ~/.databrickscfg)
dbx-dash run
# Start on a specific workspace
dbx-dash run --workspace production
# Custom refresh interval (seconds)
dbx-dash run --refresh 60
# Filter to specific workspaces
dbx-dash run --workspaces production,staging
# List configured workspaces
dbx-dash config list
# Test connectivity to a workspace
dbx-dash config check production

Configuration

[[workspace]]
name = "production"
display_name = "Prod (EU-West)"
refresh_interval = 60
[[workspace]]
name = "staging"
display_name = "Staging"
refresh_interval = 30
[refresh]
default_interval = 30
alert_on_failure = true

Keybindings

Architecture

Project layout

dbx-dash/
├── cmd/
│ └── dbx-dash/
│ └── main.go # entry point: cobra CLI → tui.Run()
├── internal/
│ ├── config/
│ │ ├── model.go # WorkspaceProfile, AppConfig, RefreshConfig
│ │ └── loader.go # parse ~/.databrickscfg (INI) + ~/.dbx-dash/config.toml
│ ├── databricks/
│ │ ├── interfaces.go # JobsProvider, ClustersProvider, WarehousesProvider, PipelinesProvider
│ │ ├── models.go # Job, JobRun, RunOutput, Cluster, SqlWarehouse, Pipeline, PipelineUpdate
│ │ ├── sdk/
│ │ │ ├── factory.go # WorkspaceClientFactory: lazy init, sync.Map cache
│ │ │ ├── jobs.go # SDKJobsProvider (databricks-sdk-go)
│ │ │ ├── clusters.go # SDKClustersProvider
│ │ │ ├── warehouses.go # SDKWarehousesProvider
│ │ │ └── pipelines.go # SDKPipelinesProvider
│ │ └── mock/
│ │ └── providers.go # MockJobsProvider, etc. (used in tests)
│ ├── cache/
│ │ ├── db.go # SQLite init, schema (modernc.org/sqlite, no CGO)
│ │ └── repository.go # UpsertJob, GetJobs, UpsertCluster, GetClusters
│ ├── tui/
│ │ ├── app.go # root bubbletea Model, Update, View
│ │ ├── keys.go # keyMap definitions
│ │ ├── styles.go # lipgloss style constants
│ │ └── screens/
│ │ ├── dashboard.go # health-card summaries per workspace
│ │ ├── jobs.go # sortable jobs table
│ │ ├── clusters.go # clusters table
│ │ ├── warehouses.go # SQL warehouses table
│ │ └── run_detail.go # job run detail + scrollable log viewer
│ └── alerts/
│ └── terminal.go # RingBell(), FlashAlert()
├── go.mod
└── README.md

Interface layer

type JobsProvider interface {
 ListJobs(ctx context.Context) ([]Job, error)
 ListRuns(ctx context.Context, jobID int64, limit int) ([]JobRun, error)
 GetRunOutput(ctx context.Context, runID int64) (*RunOutput, error)
}
type ClustersProvider interface {
 ListClusters(ctx context.Context) ([]Cluster, error)
}
type WarehousesProvider interface {
 ListWarehouses(ctx context.Context) ([]SqlWarehouse, error)
}
type PipelinesProvider interface {
 ListPipelines(ctx context.Context) ([]Pipeline, error)
 ListUpdates(ctx context.Context, pipelineID string, limit int) ([]PipelineUpdate, error)
}
// WorkspaceProviders bundles all four providers for one workspace.
type WorkspaceProviders struct {
 Jobs JobsProvider
 Clusters ClustersProvider
 Warehouses WarehousesProvider
 Pipelines PipelinesProvider
}

Domain models

// internal/databricks/models.go
type Job struct {
 JobID int64
 Name string
 Creator string
 CreatedTime time.Time
}
type JobRun struct {
 RunID int64
 JobID int64
 State string // PENDING, RUNNING, TERMINATING, TERMINATED, SKIPPED, INTERNAL_ERROR
 ResultState string // SUCCESS, FAILED, TIMEDOUT, CANCELED
 StartTime time.Time
 EndTime time.Time
 RunPageURL string
}
type RunOutput struct {
 RunID int64
 Metadata JobRun
 Error string
 ErrorTrace string
 Logs string
}
type Cluster struct {
 ClusterID string
 Name string
 State string
 NumWorkers int
 MinWorkers int
 MaxWorkers int
 NodeTypeID string
 DriverTypeID string
 SparkVersion string
 Source string
}
type SqlWarehouse struct {
 WarehouseID string
 Name string
 State string
 ClusterSize string
 NumClusters int
 ActiveSessions int
}
type Pipeline struct {
 PipelineID string
 Name string
 State string
 ClusterID string
 Creator string
 LastModified time.Time
}
type PipelineUpdate struct {
 UpdateID string
 PipelineID string
 State string
 FullRefresh bool
 Cause string
}

SDK factory (lazy init)

// internal/databricks/sdk/factory.go
type WorkspaceClientFactory struct {
 clients sync.Map // key: profile name, value: *databricks.WorkspaceClient
}
func (f *WorkspaceClientFactory) GetProviders(p config.WorkspaceProfile) (*databricks.WorkspaceProviders, error) {
 client, err := f.getOrCreate(p)
 if err != nil {
 return nil, err
 }
 return &databricks.WorkspaceProviders{
 Jobs: &SDKJobsProvider{client: client},
 Clusters: &SDKClustersProvider{client: client},
 Warehouses: &SDKWarehousesProvider{client: client},
 Pipelines: &SDKPipelinesProvider{client: client},
 }, nil
}

TUI (Bubble Tea)

func loadJobsCmd(ctx context.Context, ws string, p databricks.JobsProvider) tea.Cmd {
 return func() tea.Msg {
 jobs, err := p.ListJobs(ctx)
 return jobsLoadedMsg{workspace: ws, jobs: jobs, err: err}
 }
}

Cache (SQLite, no CGO)

Dependencies

Development

# Build
go build ./...
# Run tests
go test ./...
# Vet + lint
go vet ./...
# Run dashboard locally
go run ./cmd/dbx-dash run