marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

removed comments in worker.go

Browse Source
This commit is contained in:
Dhaval Dave
2023-10-12 16:24:37 +05:30
committed by GitHub
parent ebf58e1917
commit bea68c709c
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/worker/worker.go
+7 -7
View File
@@ -225,9 +225,9 @@ func getKubernetesClient() (*kubernetes.Clientset, error) {
// Deploys the internal worker whenever something happens // Deploys the internal worker whenever something happens
func deployApp(cli *dockerclient.Client, image string, identifier string, env []string, workflowExecution shuffle.WorkflowExecution, action shuffle.Action) error { func deployApp(cli *dockerclient.Client, image string, identifier string, env []string, workflowExecution shuffle.WorkflowExecution, action shuffle.Action) error {
log.Printf("################################### new call to deployApp ###################################") // log.Printf("################################### new call to deployApp ###################################")
log.Printf("image: %s", image) // log.Printf("image: %s", image)
log.Printf("identifier: %s", identifier) // log.Printf("identifier: %s", identifier)
// log.Printf("execution: %+v", workflowExecution) // log.Printf("execution: %+v", workflowExecution)
if os.Getenv("IS_KUBERNETES") == "true" { if os.Getenv("IS_KUBERNETES") == "true" {
@@ -246,7 +246,7 @@ func deployApp(cli *dockerclient.Client, image string, identifier string, env []
clientset, err := getKubernetesClient() clientset, err := getKubernetesClient()
if err != nil { if err != nil {
fmt.Println("[ERROR]Error getting kubernetes client:", err) fmt.Println("[ERROR]Error getting kubernetes client:", err)
os.Exit(1) // os.Exit(1)
} }
log.Printf("[DEBUG] Got kubernetes client") log.Printf("[DEBUG] Got kubernetes client")
@@ -264,8 +264,8 @@ func deployApp(cli *dockerclient.Client, image string, identifier string, env []
log.Printf("APP VERSION IS: %s", appVersion) log.Printf("APP VERSION IS: %s", appVersion)
for _, app := range workflowExecution.Workflow.Actions { for _, app := range workflowExecution.Workflow.Actions {
log.Printf("[DEBUG] App: %s, Version: %s", appName, appVersion) // log.Printf("[DEBUG] App: %s, Version: %s", appName, appVersion)
log.Printf("[DEBUG] Checking app %s with version %s", app.AppName, app.AppVersion) // log.Printf("[DEBUG] Checking app %s with version %s", app.AppName, app.AppVersion)
if app.AppName == appName && app.AppVersion == appVersion { if app.AppName == appName && app.AppVersion == appVersion {
if app.Generated == true { if app.Generated == true {
log.Printf("[DEBUG] Generated app, setting local registry") log.Printf("[DEBUG] Generated app, setting local registry")
@@ -290,7 +290,7 @@ func deployApp(cli *dockerclient.Client, image string, identifier string, env []
}, },
}, },
Spec: corev1.PodSpec{ Spec: corev1.PodSpec{
NodeName: "worker1", // change this in prod // NodeName: "worker1"
RestartPolicy: "Never", RestartPolicy: "Never",
Containers: []corev1.Container{ Containers: []corev1.Container{
{ {