[CI]【Hackathon 9th Sprint No.54】NO.54 功能模块 fastdeploy/inter_communicator/engine_worker_queue.py 单测补充 by essos-bot · Pull Request #5049 · PaddlePaddle/FastDeploy (original) (raw)

Motivation

NO.54 功能模块 fastdeploy/inter_communicator/engine_worker_queue.py 单测补充

Modifications

NO.54 功能模块 fastdeploy/inter_communicator/engine_worker_queue.py 单测补充

Usage or Command

no need

Accuracy Tests

no

Checklist

• Add at least a tag in the PR title.
  • Tag list: [][FDConfig],[APIServer],[Engine], [Scheduler], [PD Disaggregation], [Executor], [Graph Optimization], [Speculative Decoding], [RL], [Models], [Quantization], [Loader], [OP], [KVCache], [DataProcessor], [BugFix], [Docs], [CI], [Optimization], [Feature], [Benchmark], [Others], [XPU], [HPU], [GCU], [DCU], [Iluvatar], [Metax]]
  • You can add new tags based on the PR content, but the semantics must be clear.
• Format your code, run pre-commit before commit.
• Add unit tests. Please write the reason in this PR if no unit tests.
• Provide accuracy results.
• If the current PR is submitting to the release branch, make sure the PR has been submitted to the develop branch, then cherry-pick it to the release branch with the [Cherry-Pick] PR tag.

• Add comprehensive test suite for EngineWorkerQueue class
• Cover server/client initialization, connection management
• Test task queue operations, cache info handling
• Include RDMA task operations and barrier synchronization
• Add multi-client and thread safety tests
• Test tensor conversion functionality
• Verify data parallel operations and edge cases

🤖 Generated with Claude Code

Co-Authored-By: Claude noreply@anthropic.com

Thanks for your contribution!

• Move QueueManager class to module level to fix pickle serialization for multiprocessing
• Add comprehensive fallback mechanism for multiprocessing failures in CI environment
• Implement _create_engine_worker_queue_with_fallback method for graceful degradation
• Add FD_TEST_MULTIPROCESSING environment variable to control multiprocessing behavior
• Fix AttributeError: 'EngineWorkerQueue' object has no attribute 'lock' and similar errors
• Ensure all pre-commit checks pass (black, isort, flake8, ruff)
• Tests now pass in both normal and fallback modes

🤖 Generated with Claude Code

Co-Authored-By: Claude noreply@anthropic.com

…r_queue.py"

This reverts commit 71642bd.