Skip to content

Commit

Permalink
Temp. disable TestWorkerRunKubernetesExecutor test
Browse files Browse the repository at this point in the history
- Re-enable when in-cluster K8s is up and running!
  • Loading branch information
lbeckman314 committed Oct 22, 2024
1 parent 716411f commit 91c3661
Showing 1 changed file with 0 additions and 39 deletions.
39 changes: 0 additions & 39 deletions tests/core/worker_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -437,42 +437,3 @@ func TestWorkerRunBase64TaskReader(t *testing.T) {
t.Error("unexpected task state")
}
}

func TestWorkerRunKubernetesExecutor(t *testing.T) {
tests.SetLogOutput(log, t)
conf := tests.DefaultConfig()
task := tes.Task{
Id: "test-task-" + tes.GenerateID(),
Executors: []*tes.Executor{
{
Image: "alpine",
Command: []string{"echo", "Hello, World!"},
},
},
}

counts := &eventCounter{}
logger := &events.Logger{Log: log}
m := &events.MultiWriter{logger, counts}

w := worker.DefaultWorker{
Conf: conf.Worker,
Store: &storage.Mux{},
TaskReader: taskReader{&task},
EventWriter: m,
}

w.Executor.Backend = "kubernetes"

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()

err := w.Run(ctx)
if err != nil {
t.Fatal("unexpected error", err)
}

// if task.State != tes.Complete {
// t.Error("unexpected task state")
// }
}

0 comments on commit 91c3661

Please sign in to comment.