This is an automated email from the ASF dual-hosted git repository.
squakez pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/main by this push:
new 3f3d0857e fix(e2e): delete pipes, not integrations
3f3d0857e is described below
commit 3f3d0857ebc3a34b81de95a855fb860c8304b033
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Thu Oct 1 12:45:07 2026 +0200
fix(e2e): delete pipes, not integrations
---
e2e/kafka/kafka_autoscale_keda_test.go | 4 ++--
pkg/cmd/root_test.go | 11 -----------
2 files changed, 2 insertions(+), 13 deletions(-)
diff --git a/e2e/kafka/kafka_autoscale_keda_test.go
b/e2e/kafka/kafka_autoscale_keda_test.go
index 68c71e151..7c05e50fa 100644
--- a/e2e/kafka/kafka_autoscale_keda_test.go
+++ b/e2e/kafka/kafka_autoscale_keda_test.go
@@ -64,11 +64,11 @@ func TestKafkaKedaAutoscale(t *testing.T) {
// Verify we are consuming some record (the body is
null as the timer is pushing nothing)
g.Eventually(IntegrationLogs(t, ctx, ns,
consumerName)).Should(ContainSubstring("Body is null"))
// Stop the producer
- ExpectExecSucceed(t, g, Kubectl("delete", "it",
producerName, "-n", ns))
+ ExpectExecSucceed(t, g, Kubectl("delete", "pipe",
producerName, "-n", ns))
// Consumer should scale back to 0 after some time as
there is no longer traffic
g.Eventually(IntegrationStatusReplicas(t, ctx, ns,
consumerName), TestTimeoutMedium).
Should(gstruct.PointTo(BeNumerically("==", 0)))
- ExpectExecSucceed(t, g, Kubectl("delete", "it",
"--all", "-n", ns))
+ ExpectExecSucceed(t, g, Kubectl("delete", "pipe",
"--all", "-n", ns))
})
}, "kafka")
}
diff --git a/pkg/cmd/root_test.go b/pkg/cmd/root_test.go
index 8e8305a55..574d39b05 100644
--- a/pkg/cmd/root_test.go
+++ b/pkg/cmd/root_test.go
@@ -52,17 +52,6 @@ func kamelTestPreAddCommandInit() (*RootCmdOptions,
*cobra.Command) {
return kamelTestPreAddCommandInitWithClient(fakeClient)
}
-func TestDeprecatedCommandsAreNotRegistered(t *testing.T) {
- command, err := NewKamelCommand(context.Background())
- require.NoError(t, err)
-
- for _, name := range []string{"delete", "get", "kit"} {
- found, _, err := command.Find([]string{name})
- require.Error(t, err)
- require.Same(t, command, found)
- }
-}
-
func TestLoadFromEnvVar(t *testing.T) {
// shows how to include a "," character inside an env value see VAR1
value
require.NoError(t, os.Setenv("KAMEL_RUN_ENVS",
"\"VAR1=value,\"\"othervalue\"\"\",VAR2=value2"))
