k8s workflow uses its own kafka server name

astrolabsoftware · Jan 31, 2025 · c0af67e · c0af67e
1 parent 447f5ba
commit c0af67e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/.github/workflows/e2e-common.yml b/.github/workflows/e2e-common.yml
@@ -138,10 +138,10 @@ jobs:
           else
             echo "Using pre-existing image from registry (See  "Ciux project ignition" section)"
           fi
-      - name: Setup tmate session
-        uses: mxschmitt/action-tmate@v3
-        with:
-          detached: true
+      # - name: Setup tmate session
+      # uses: mxschmitt/action-tmate@v3
+      # with:
+      # detached: true
       - name: Run argoCD
         run: |
           ./e2e/argocd.sh -S "${{ matrix.storage }}"

diff --git a/bin/ztf/stream2raw.py b/bin/ztf/stream2raw.py
@@ -93,8 +93,10 @@ def main():
         alert_schema, _, alert_schema_json = get_schemas_from_avro(args.schema)
 
     # Decode the Avro data, and keep only (timestamp, data)
-    if args.servers.startswith("localhost"):
-        # Only for test suite
+    if args.servers.startswith("localhost") or args.servers.startswith(
+        "kafka-cluster-kafka-bootstrap.kafka"
+    ):
+        # Only for test suite (sentinel or k8s)
         df_decoded = df.select([
             from_avro(df["value"], alert_schema_json).alias("decoded")
         ])