Adding thread sleep before deleting resources in integ test (#236)

Author: jam-jee

test/integration_tests/training/cli/test_gpu_quota_allocation.py

@@ -37,6 +37,10 @@ def test_create_job_with_integer_quota_parameters(self, test_job_name):
         ]
 
         result = execute_command(create_cmd)
+
+        # Wait a moment for the job to be created
+        time.sleep(5)
+
         assert result.returncode == 0
         assert "Using version: 1.1" in result.stdout
         logger.info(f"Successfully created job with required gpu quota parameters: {test_job_name}")
@@ -84,6 +88,10 @@ def test_create_job_with_float_quota_parameters(self, test_job_name):
         ]
 
         result = execute_command(create_cmd)
+
+        # Wait a moment for the job to be created
+        time.sleep(5)
+
         assert result.returncode == 0
         assert "Using version: 1.1" in result.stdout
         logger.info(f"Successfully created job with required gpu quota parameters: {test_job_name}")
@@ -126,6 +134,10 @@ def test_create_job_with_only_accelerators_parameter(self, test_job_name):
         ]
 
         result = execute_command(create_cmd)
+
+        # Wait a moment for the job to be created
+        time.sleep(5)
+
         assert result.returncode == 0
         assert "Using version: 1.1" in result.stdout
         logger.info(f"Successfully created job with required gpu quota parameters: {test_job_name}")
@@ -179,6 +191,10 @@ def test_create_job_with_accelerators_memory_parameters(self, test_job_name):
             "--namespace", NAMESPACE
         ]
         result = execute_command(describe_cmd)
+
+        # Wait a moment for the job to be created
+        time.sleep(5)
+
         assert result.returncode == 0
         assert "      Limits:   {'memory': '2899102924800m', 'nvidia.com/gpu': '1'}" in result.stdout
         assert "      Requests: {'cpu': '32', 'memory': '2040109465600m', 'nvidia.com/gpu': '1'}" in result.stdout

test/integration_tests/training/cli/test_topology.py

@@ -41,6 +41,10 @@ def test_create_job_with_required_topology(self, test_job_name):
             "--namespace", NAMESPACE
         ]
         result = execute_command(describe_cmd)
+
+        # Wait a moment for the job to be created
+        time.sleep(5)
+
         assert result.returncode == 0
         assert f"Annotations:    {{'kueue.x-k8s.io/podset-required-topology': '{TOPOLOGY}'}}" in result.stdout