increase sleep (#51)

* increase sleep * retry * fix * fix * test * test * fix
logzio · Nov 27, 2022 · 465423c · 465423c
1 parent ab13429
commit 465423c
Show file tree

Hide file tree

Showing 3 changed files with 78 additions and 18 deletions.
diff --git a/Kubernetes/AKS/Kubernetes/prerequisites/linux/functions.bash b/Kubernetes/AKS/Kubernetes/prerequisites/linux/functions.bash
@@ -73,10 +73,20 @@ function can_k8s_cluster_connect_to_logzio_logs () {
         return 3
     fi
 
-    sleep 5
+    local is_pod_completed=false
+    local retries=3
+    while [[ $retries -ne 0 ]]; do
+        local pod_status=$(kubectl get pods | grep logzio-logs-connection-test | tr -s ' ' | cut -d ' ' -f3)
+        if [[ "$pod_status" == "Completed" ]]; then
+            is_pod_completed=true
+            break
+        fi
+
+        sleep 5
+        ((retries--))
+    done
 
-    local pod_status=$(kubectl get pods | grep logzio-logs-connection-test | tr -s ' ' | cut -d ' ' -f3)
-    if [[ "$pod_status" != "Completed" ]]; then
+    if ! $is_pod_completed; then
         local pod_logs=$(kubectl logs logzio-logs-connection-test 2>$task_error_file)
         local err=$(cat $task_error_file)
 
@@ -129,10 +139,20 @@ function can_k8s_cluster_connect_to_logzio_metrics () {
         return 3
     fi
 
-    sleep 5
+    local is_pod_completed=false
+    local retries=3
+    while [[ $retries -ne 0 ]]; do
+        local pod_status=$(kubectl get pods | grep logzio-metrics-connection-test | tr -s ' ' | cut -d ' ' -f3)
+        if [[ "$pod_status" == "Completed" ]]; then
+            is_pod_completed=true
+            break
+        fi
+
+        sleep 5
+        ((retries--))
+    done
 
-    local pod_status=$(kubectl get pods | grep logzio-metrics-connection-test | tr -s ' ' | cut -d ' ' -f3)
-    if [[ "$pod_status" != "Completed" ]]; then
+    if ! $is_pod_completed; then
         local pod_logs=$(kubectl logs logzio-metrics-connection-test 2>$task_error_file)
         local err=$(cat $task_error_file)
 

diff --git a/Kubernetes/EKS/Kubernetes/prerequisites/linux/functions.bash b/Kubernetes/EKS/Kubernetes/prerequisites/linux/functions.bash
@@ -73,10 +73,20 @@ function can_k8s_cluster_connect_to_logzio_logs () {
         return 3
     fi
 
-    sleep 5
+    local is_pod_completed=false
+    local retries=3
+    while [[ $retries -ne 0 ]]; do
+        local pod_status=$(kubectl get pods | grep logzio-logs-connection-test | tr -s ' ' | cut -d ' ' -f3)
+        if [[ "$pod_status" == "Completed" ]]; then
+            is_pod_completed=true
+            break
+        fi
+
+        sleep 5
+        ((retries--))
+    done
 
-    local pod_status=$(kubectl get pods | grep logzio-logs-connection-test | tr -s ' ' | cut -d ' ' -f3)
-    if [[ "$pod_status" != "Completed" ]]; then
+    if ! $is_pod_completed; then
         local pod_logs=$(kubectl logs logzio-logs-connection-test 2>$task_error_file)
         local err=$(cat $task_error_file)
 
@@ -129,10 +139,20 @@ function can_k8s_cluster_connect_to_logzio_metrics () {
         return 3
     fi
 
-    sleep 5
+    local is_pod_completed=false
+    local retries=3
+    while [[ $retries -ne 0 ]]; do
+        local pod_status=$(kubectl get pods | grep logzio-metrics-connection-test | tr -s ' ' | cut -d ' ' -f3)
+        if [[ "$pod_status" == "Completed" ]]; then
+            is_pod_completed=true
+            break
+        fi
+
+        sleep 5
+        ((retries--))
+    done
 
-    local pod_status=$(kubectl get pods | grep logzio-metrics-connection-test | tr -s ' ' | cut -d ' ' -f3)
-    if [[ "$pod_status" != "Completed" ]]; then
+    if ! $is_pod_completed; then
         local pod_logs=$(kubectl logs logzio-metrics-connection-test 2>$task_error_file)
         local err=$(cat $task_error_file)
 

diff --git a/Kubernetes/GKE/Kubernetes/prerequisites/linux/functions.bash b/Kubernetes/GKE/Kubernetes/prerequisites/linux/functions.bash
@@ -81,10 +81,20 @@ function can_k8s_cluster_connect_to_logzio_logs () {
         return 3
     fi
 
-    sleep 5
+    local is_pod_completed=false
+    local retries=3
+    while [[ $retries -ne 0 ]]; do
+        local pod_status=$(kubectl get pods | grep logzio-logs-connection-test | tr -s ' ' | cut -d ' ' -f3)
+        if [[ "$pod_status" == "Completed" ]]; then
+            is_pod_completed=true
+            break
+        fi
+
+        sleep 5
+        ((retries--))
+    done
 
-    local pod_status=$(kubectl get pods | grep logzio-logs-connection-test | tr -s ' ' | cut -d ' ' -f3)
-    if [[ "$pod_status" != "Completed" ]]; then
+    if ! $is_pod_completed; then
         local pod_logs=$(kubectl logs logzio-logs-connection-test 2>$task_error_file)
         local err=$(cat $task_error_file)
 
@@ -141,10 +151,20 @@ function can_k8s_cluster_connect_to_logzio_metrics () {
         return 3
     fi
 
-    sleep 5
+    local is_pod_completed=false
+    local retries=3
+    while [[ $retries -ne 0 ]]; do
+        local pod_status=$(kubectl get pods | grep logzio-metrics-connection-test | tr -s ' ' | cut -d ' ' -f3)
+        if [[ "$pod_status" == "Completed" ]]; then
+            is_pod_completed=true
+            break
+        fi
+
+        sleep 5
+        ((retries--))
+    done
 
-    local pod_status=$(kubectl get pods | grep logzio-metrics-connection-test | tr -s ' ' | cut -d ' ' -f3)
-    if [[ "$pod_status" != "Completed" ]]; then
+    if ! $is_pod_completed; then
         local pod_logs=$(kubectl logs logzio-metrics-connection-test 2>$task_error_file)
         local err=$(cat $task_error_file)