Merged
Conversation
- Updated the documentation for the Python API, improving clarity and consistency in naming conventions and examples. - Introduced new functions for mounting and unmounting Python objects to the Pulsing network, facilitating better integration with Ray. - Enhanced the `resolve` function to support a timeout parameter, allowing for retries until an actor name appears or the timeout expires. - Added a new `pulsing.examples` module with built-in examples, showcasing the capabilities of Pulsing in a distributed environment. - Implemented tests for the new Ray integration features, ensuring robust functionality and error handling across various scenarios.
- Streamlined the Python API by consolidating actor initialization and lifecycle management, emphasizing the use of `await pul.init()` and `await pul.shutdown()`. - Updated examples and documentation to reflect the new API structure, enhancing clarity and usability for users transitioning from Ray. - Introduced typed and untyped proxy methods (`as_type` and `as_any`) for better actor reference handling. - Removed deprecated Ray-compatible API references, focusing on the native async API for improved performance and simplicity. - Enhanced examples to demonstrate the new features and best practices in actor management and communication.
- Added "Complete Reference" to the navigation structure in mkdocs for better accessibility to API documentation. - Updated the API reference section to include new global async API examples, emphasizing the use of `await pul.init()` and `await pul.shutdown()`. - Enhanced clarity in the documentation by refining the descriptions and examples related to actor management and communication. - Improved consistency in naming conventions across English and Chinese documentation to facilitate user understanding.
- Updated the documentation to reflect the new Queue and Topic APIs, emphasizing the use of `pul.queue` and `pul.topic` for data handling. - Simplified examples across various documentation files to demonstrate the new API structure, enhancing clarity for users. - Removed deprecated references to `system.queue` and `system.topic`, ensuring consistency in the API usage. - Improved the organization of the queue and topic sections in the guides and API references for better accessibility and understanding.
- Introduced a new document detailing the Cluster Networking features, explaining how to form and operate a Pulsing cluster with three distinct networking modes. - Updated mkdocs configuration to include the new Cluster Networking section in both English and Chinese, enhancing accessibility for users. - Improved navigation structure in mkdocs to reflect the addition of Cluster Networking, ensuring users can easily find relevant documentation. - Adjusted existing architecture documentation to include links to the new Cluster Networking document, providing a comprehensive overview of the system's design.
- Changed repository URLs from "reiase" to "DeepLink-org" across multiple files, ensuring consistency in project references. - Updated the project description to emphasize Pulsing as a backbone for distributed AI systems, highlighting its features such as streaming support and zero dependencies. - Enhanced the README and documentation to provide clearer insights into Pulsing's capabilities and use cases, improving accessibility for users. - Added an overview document to summarize Pulsing's functionality and target audience, facilitating better understanding for new users.
- Updated import statements in various benchmark scripts to utilize the new `pulsing.streaming` and `pulsing.core` modules, ensuring consistency and clarity in the codebase. - Removed deprecated references to `pulsing.actor` and `pulsing.queue`, streamlining the API usage in benchmarks. - Introduced a new `pulsing.integrations` module to better organize third-party integrations and improve overall project structure. - Enhanced documentation and comments to reflect the changes in module organization, aiding user understanding and accessibility.
- Updated import statements across various documentation files to reflect the new module structure, replacing `pulsing.actor` and `pulsing.queue` with `pulsing.core` and `pulsing.streaming`. - Enhanced examples and guides to demonstrate the updated import paths, ensuring consistency and clarity for users. - Improved documentation for actor and queue functionalities, emphasizing the new organization under `pulsing.integrations` and `pulsing.serving`. - Streamlined references to actor management and queue operations, aiding user understanding and accessibility.
…ilities - Introduced an optional zerocopy descriptor protocol to bypass pickle serialization for eligible Python objects, improving performance for large payloads. - Implemented automatic stream transfer for large payloads exceeding a specified threshold, allowing for efficient data handling in chunks. - Updated the `ZeroCopyDescriptor` class to manage metadata and buffer information, facilitating seamless integration with existing APIs. - Enhanced the `StorageBackend` interface with new tensor-native methods for better data management. - Added comprehensive tests to validate the new zerocopy functionality and ensure data integrity during transmission. - Updated documentation to reflect the new features and usage guidelines for the zerocopy protocol, improving clarity for users.
…tion - Included `pytest-cov` in the development dependencies for improved test coverage reporting. - Updated comments and documentation in `test_receive_error_behavior.py` for clarity and consistency. - Added new test files for agent runtime lifecycle, CLI commands, and streaming backends, enhancing overall test coverage and organization. - Improved existing tests to ensure better readability and maintainability, aligning with recent refactoring efforts.
![github-advanced-security[bot]](https://avatars.githubusercontent.com/in/57789?s=60&v=4){kind=small}
Contributor
There was a problem hiding this comment.
CodeQL found more than 20 potential problems in the proposed changes. Check the Files changed tab for more details.
… consistent environment execution during CI tests
…detection and error handling - Updated the CI test command to check for available Python interpreters instead of relying on `uv run`, ensuring compatibility with various environments. - Enhanced error messaging to inform users when no Python interpreter is found, improving usability during CI processes.
- Updated the assertion in `test_concurrent_init_without_driver` to store the popped seed in a variable before checking its presence in the addresses, improving code readability and maintainability.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Overview:
Details:
Where should the reviewer start?
Related Issues: (use one of the action keywords Closes / Fixes / Resolves / Relates to)