Skip to content

Commit

Permalink
Temporarily remove K8s tests until in-cluster test is added
Browse files Browse the repository at this point in the history
  • Loading branch information
lbeckman314 committed Oct 14, 2024
1 parent eca785d commit 75309b6
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 106 deletions.
1 change: 0 additions & 1 deletion deployments/kubernetes/README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
> [!WARNING]
> Funnel's Kubernetes support is in active development and may involve frequent updates 🚧
# Overview
Expand Down
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")
// }
}
66 changes: 0 additions & 66 deletions worker/kubernetes_test.go

This file was deleted.

0 comments on commit 75309b6

Please sign in to comment.