lint

Author: pawelpaszki

tests/e2e/rayjob_existing_cluster_kind_test.py

@@ -108,31 +108,37 @@ def assert_rayjob_submit_against_existing_cluster(
         # Debug: Check if RayJob resource was actually created
         import subprocess
         import time
-        
+
         print("🔍 Checking if RayJob resource exists in Kubernetes...")
         for attempt in range(6):  # Check for 30 seconds
             try:
                 # Check if RayJob resource exists
                 result = subprocess.run(
                     ["kubectl", "get", "rayjobs", "-n", self.namespace, job_name],
-                    capture_output=True, text=True, timeout=10
+                    capture_output=True,
+                    text=True,
+                    timeout=10,
                 )
                 if result.returncode == 0:
                     print(f"✅ RayJob resource '{job_name}' found in Kubernetes!")
                     print(f"RayJob details:\n{result.stdout}")
                     break
                 else:
-                    print(f"❌ Attempt {attempt + 1}: RayJob resource '{job_name}' not found")
+                    print(
+                        f"❌ Attempt {attempt + 1}: RayJob resource '{job_name}' not found"
+                    )
                     if attempt < 5:
                         time.sleep(5)
             except Exception as e:
                 print(f"❌ Error checking RayJob: {e}")
-                
+
         # Also check what RayJob resources exist in the namespace
         try:
             result = subprocess.run(
                 ["kubectl", "get", "rayjobs", "-n", self.namespace],
-                capture_output=True, text=True, timeout=10
+                capture_output=True,
+                text=True,
+                timeout=10,
             )
             print(f"📋 All RayJobs in namespace '{self.namespace}':\n{result.stdout}")
         except Exception as e: