From fb7b32682d439cf6f0a0d8931f4bcc2c4b9b969c Mon Sep 17 00:00:00 2001 From: Aditya <60684641+0x0elliot@users.noreply.github.com> Date: Fri, 5 Jul 2024 19:14:30 +0530 Subject: [PATCH] fix[k8s]: app replication works at scale --- functions/onprem/orborus/orborus.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go index ffc306e6..b1688487 100755 --- a/functions/onprem/orborus/orborus.go +++ b/functions/onprem/orborus/orborus.go @@ -754,7 +754,7 @@ func fixk8sRoles() { }, Rules: []rbacv1.PolicyRule{ { - APIGroups: []string{""}, + APIGroups: []string{"", "apps"}, Resources: resourceTypes, Verbs: []string{"create", "list"}, }, @@ -1026,6 +1026,7 @@ func deployK8sWorker(image string, identifier string, env []string) error { log.Printf("[ERROR] %s is not a valid number for replication", replicaNumberStr) } else { replicaNumber = tmpInt + } } @@ -3200,7 +3201,7 @@ func sendWorkerRequest(workflowExecution shuffle.ExecutionRequest, image string, debugCommand := fmt.Sprintf("docker service logs shuffle-workers 2>&1 -f | grep %s", workflowExecution.ExecutionId) if isKubernetes == "true" { - debugCommand = fmt.Sprintf("kubectl logs -n %s %s | grep %s", kubernetesNamespace, identifier, workflowExecution.ExecutionId) + debugCommand = fmt.Sprintf("kubectl logs -n %s container=shuffle-worker | grep %s", kubernetesNamespace, workflowExecution.ExecutionId) } log.Printf("[DEBUG] Ran worker from request with execution ID: %s. Worker URL: %s. DEBUGGING:\n%s", workflowExecution.ExecutionId, streamUrl, debugCommand)