[tests/scenarios] launching python nodes with producer and consumers

[just] trying to fix `wait-pods` error: `no matching resources found`

Author: khoaguin

justfile

@@ -536,6 +536,9 @@ yank-ns kube_context namespace:
 [group('utils')]
 @wait-pods kube_context namespace:
     echo "Waiting for all pods to be ready in cluster={{ kube_context }} namespace={{ namespace }}"
+    # Wait for at least one pod to appear (timeout after 5 minutes)
+    timeout 300 bash -c 'until kubectl get pods --context {{ kube_context }} --namespace {{ namespace }} 2>/dev/null | grep -q ""; do sleep 5; done'
+
     kubectl wait --for=condition=ready pod --all --timeout=300s --context {{ kube_context }} --namespace {{ namespace }}
 
     # if the above doesn't wait as we expect the drop the above and use the below

tests/scenariosv2/flows/utils.py

@@ -22,4 +22,11 @@ def launch_server(ctx: SimulatorContext, server_url: str, server_name: str):
         ctx.logger.info(f"Launching python server '{server_name}' at {server_url}")
         parsed_url = urlparse(server_url)
         port = parsed_url.port
-        sy.orchestra.launch(name=server_name, reset=True, dev_mode=True, port=port)
+        sy.orchestra.launch(
+            name=server_name,
+            reset=True,
+            dev_mode=True,
+            port=port,
+            create_producer=True,
+            n_consumers=1,
+        )