diff --git a/functions/onprem/orborus/go.mod b/functions/onprem/orborus/go.mod index 00afcaab..64b342c1 100644 --- a/functions/onprem/orborus/go.mod +++ b/functions/onprem/orborus/go.mod @@ -10,7 +10,7 @@ require ( github.com/docker/docker v27.0.2+incompatible github.com/docker/go-connections v0.5.0 github.com/satori/go.uuid v1.2.0 - github.com/shuffle/shuffle-shared v0.6.59 + github.com/shuffle/shuffle-shared v0.6.60 k8s.io/api v0.30.2 k8s.io/apimachinery v0.30.2 k8s.io/client-go v0.30.2 diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go index 2aff9cd0..52ded02a 100755 --- a/functions/onprem/orborus/orborus.go +++ b/functions/onprem/orborus/orborus.go @@ -2030,7 +2030,7 @@ func main() { } toBeRemoved.Data = append(toBeRemoved.Data, incRequest) - + } else if incRequest.Type == "CATEGORY_UPDATE" { err := deployTenzirNode() @@ -2087,7 +2087,7 @@ func main() { toBeRemoved.Data = append(toBeRemoved.Data, incRequest) } else if incRequest.Type == "START_TENZIR" { - + log.Printf("[INFO] Got job to start tenzir") err := deployTenzirNode() if err != nil{ log.Printf("[ERROR] failed to deploy the pipeline, reason: %s", err)