fix: use fluvio_bin env instead fluvio directly (#3960)

infinyon · Apr 22, 2024 · 116276a · 116276a
1 parent 4c32ba3
commit 116276a
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 13 deletions.
diff --git a/tests/cli/cdk_smoke_tests/cdk-multi-partition-consumer.bats b/tests/cli/cdk_smoke_tests/cdk-multi-partition-consumer.bats
@@ -54,8 +54,8 @@ EOF
     wait_for_line_in_file "succesfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
-    echo 1:1 | fluvio produce $TOPIC_NAME --key-separator ":"
-    echo 4:4 | fluvio produce $TOPIC_NAME --key-separator ":"
+    echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
+    echo 4:4 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
 
     wait_for_line_in_file "Received record: 4" $LOG_PATH 30
 
@@ -103,8 +103,8 @@ EOF
     wait_for_line_in_file "succesfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
-    echo 1:1 | fluvio produce $TOPIC_NAME --key-separator ":"
-    echo 4:4 | fluvio produce $TOPIC_NAME --key-separator ":"
+    echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
+    echo 4:4 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
 
     wait_for_line_in_file "Received record: 4" $LOG_PATH 30
     wait_for_line_in_file "Received record: 1" $LOG_PATH 2
@@ -151,9 +151,9 @@ EOF
     wait_for_line_in_file "succesfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
-    echo 3:3 | fluvio produce $TOPIC_NAME --key-separator ":"
-    echo 1:1 | fluvio produce $TOPIC_NAME --key-separator ":"
-    echo 2:2 | fluvio produce $TOPIC_NAME --key-separator ":"
+    echo 3:3 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
+    echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
+    echo 2:2 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
 
     wait_for_line_in_file "Received record: 2" $LOG_PATH 30
     wait_for_line_in_file "Received record: 1" $LOG_PATH 2
@@ -235,9 +235,9 @@ EOF
     wait_for_line_in_file "succesfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
-    echo 1:1 | fluvio produce $TOPIC_NAME --key-separator ":"
+    echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
     sleep 2
-    echo 4:4 | fluvio produce $TOPIC_NAME --key-separator ":"
+    echo 4:4 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
     sleep 2
 
     wait_for_line_in_file "Received record: 1" $LOG_PATH 30

diff --git a/tests/cli/fluvio_smoke_tests/consumer-offset.bats b/tests/cli/fluvio_smoke_tests/consumer-offset.bats
@@ -14,10 +14,10 @@ setup_file() {
     debug_msg "Topic name: $TOPIC_NAME"
     run timeout 15s "$FLUVIO_BIN" topic create "$TOPIC_NAME" --partitions 2
 
-    echo 1:1 | fluvio produce $TOPIC_NAME --key-separator ":"
-    echo 2:2 | fluvio produce $TOPIC_NAME --key-separator ":"
-    echo 4:4 | fluvio produce $TOPIC_NAME --key-separator ":"
-    echo 8:8 | fluvio produce $TOPIC_NAME --key-separator ":"
+    echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
+    echo 2:2 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
+    echo 4:4 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
+    echo 8:8 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
 }
 
 @test "Consumer Offsets topic exist" {