Fix test warnings#1061
Conversation
Codecov Report❌ Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #1061 +/- ##
==========================================
+ Coverage 72.43% 72.92% +0.49%
==========================================
Files 21 21
Lines 5100 5090 -10
==========================================
+ Hits 3694 3712 +18
+ Misses 1406 1378 -28
Flags with carried forward coverage won't be shown. Click here to find out more.
🚀 New features to boost your workflow:
|
- Add timeout (600s) and error handling to TPI.py client.gather() with fallback to serial computation - Increase SS.py client.gather() timeout from 300s to 600s for consistency - Update SS.py to use logging.warning instead of print for better consistency - Adjust LocalCluster timeouts in test_TPI.py fixture: - Increase memory_limit from 2GB to 3GB - Increase communication timeout from 300s to 900s - Increase heartbeat_interval from 10s to 30s - Increase death_timeout from 60s to 120s These changes address issues with long-running computationally intensive tasks where communication can break down due to overly aggressive timeouts. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
The previous commit incorrectly used client.gather(timeout=) which is not a valid parameter. This commit fixes the implementation to use the correct approach: - Use distributed.wait() with timeout to wait for futures to complete - Check if any futures did not complete (not_done) and raise TimeoutError - Only call client.gather() after confirming all futures are done - Maintain the same error handling and fallback to serial computation This properly implements timeout handling for long-running dask computations in both TPI.py and SS.py. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
|
@jdebacker. I have reviewed the code of this PR and approved it. Is it ready to merge? |
|
@rickecon Changing to WIP -- still resolving some local tests (dask timing out in some TPI full runs) and looking to improve performance. |
|
@jdebacker. I came back to this PR to try to get it merged in. I have gone through all the code. I just want to test it on my local machine, but I noticed that it is two commits behind the master branch. If you would update this branch, I would love to get it tested and merged in. |
|
All local tests seem to pass (though still waiting on the 2nd of the 4 tests in |
|
@jdebacker. Looks great. Merging now. |
This PR seeks to address Issue #1047 and reduce the number of pytest warnings.