We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b233641 commit 64ce5b4Copy full SHA for 64ce5b4
tests/e2e/local_interactive_sdk_kind_test.py
@@ -85,8 +85,17 @@ def heavy_calculation(num_iterations):
85
return sum(results)
86
87
ref = heavy_calculation.remote(3000)
88
- result = ray.get(ref)
89
- assert result == 1789.4644387076714
+
+ job_timeout_seconds = 900
90
+ try:
91
+ print(f"Waiting for Ray job result with timeout={job_timeout_seconds}s...")
92
+ result = ray.get(ref, timeout=job_timeout_seconds)
93
+ print("Ray job completed successfully.")
94
95
+ assert result == 1789.4644387076714
96
+ except ray.exceptions.GetTimeoutError:
97
+ pytest.fail(f"Ray job timed out after {job_timeout_seconds} seconds.")
98
99
ray.cancel(ref)
100
ray.shutdown()
101
0 commit comments