Skip to content

Feature/code refine#56

Open
reiase wants to merge 5 commits intomainfrom
feature/code_refine
Open

Feature/code refine#56
reiase wants to merge 5 commits intomainfrom
feature/code_refine

Conversation

@reiase
Copy link
Contributor

@reiase reiase commented Mar 1, 2026

Overview:

Details:

Where should the reviewer start?

Related Issues: (use one of the action keywords Closes / Fixes / Resolves / Relates to)

  • closes GitHub issue: #xxx

reiase added 5 commits March 1, 2026 01:09
… creation

- Updated `Http2RemoteTransport` to utilize a builder pattern, enhancing flexibility in specifying transport targets (by name, ID, or hierarchical path).
- Introduced `TransportTarget` enum to clearly define the target type for remote actors.
- Refactored related code in `ActorSystem` to align with the new transport creation method, improving readability and maintainability.
- Enhanced tests to validate the new builder functionality and ensure correct behavior across various transport scenarios.
- Removed unused imports and refactored actor service references in `__init__.py` for better readability.
- Consolidated actor service registration in `actor_system` to enhance clarity and maintainability.
- Streamlined the `Remote` API in `router.py` by introducing a helper method for chunk building, reducing code duplication.
- Updated `RustSchedulerBase` and its subclasses to improve worker selection logic and enhance code organization.
- Refactored `StorageManager` to simplify bucket and topic management, improving locking mechanisms and resource handling.
- Enhanced `SyncQueue` and `SyncQueueReader` to utilize a common synchronous execution method, improving code consistency.
- Updated tests to reflect changes in actor proxy handling and ensure robust functionality across various scenarios.
- Removed unused imports and consolidated actor service references in `__init__.py` for improved readability.
- Updated `_GlobalQueueAPI` and `_GlobalTopicAPI` to utilize direct queue and topic writing/reading functions, enhancing clarity.
- Introduced new `protocol.py` and `proxy.py` files to encapsulate message serialization and actor proxy functionalities, streamlining the codebase.
- Refactored `remote.py` to remove redundant methods and improve organization, focusing on actor lifecycle management.
- Enhanced `service.py` with a dedicated `PythonActorService` for better actor creation handling and improved error management.
- Updated documentation and tests to reflect changes in actor management and API structure, ensuring robust functionality.
- Streamlined the Python API documentation by reorganizing sections for clarity, including lifecycle management, actor definition, and usage examples.
- Enhanced actor management details, including initialization, spawning, and resolution methods, to improve user understanding.
- Updated examples to reflect new API structures and best practices, ensuring consistency and clarity in usage.
- Removed outdated sections and consolidated information to provide a more cohesive and user-friendly documentation experience.
- Updated the `resolve` function to support typed proxies, allowing for direct method calls without needing to use `.as_type()` or `.as_any()`.
- Improved documentation across multiple files to clarify the usage of `pul.resolve()` for both typed and untyped proxies, enhancing user understanding.
- Refactored examples to demonstrate the new resolution capabilities and best practices for actor management.
- Consolidated references to actor resolution methods in the API documentation, ensuring consistency and clarity for users transitioning from previous versions.
Copy link
Contributor

@github-advanced-security github-advanced-security bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CodeQL found more than 20 potential problems in the proposed changes. Check the Files changed tab for more details.

@codecov-commenter
Copy link

Codecov Report

❌ Patch coverage is 65.82278% with 270 lines in your changes missing coverage. Please review.

Files with missing lines Patch % Lines
python/pulsing/serving/router.py 0.00% 58 Missing ⚠️
python/pulsing/core/helpers.py 11.76% 45 Missing ⚠️
python/pulsing/streaming/manager.py 61.72% 31 Missing ⚠️
python/pulsing/streaming/storage.py 11.11% 24 Missing ⚠️
python/pulsing/core/remote.py 72.22% 20 Missing ⚠️
python/pulsing/serving/scheduler.py 0.00% 20 Missing ⚠️
python/pulsing/streaming/broker.py 84.33% 13 Missing ⚠️
python/pulsing/integrations/autogen/runtime.py 0.00% 11 Missing ⚠️
python/pulsing/serving/load_stream.py 0.00% 10 Missing ⚠️
python/pulsing/core/service.py 90.10% 9 Missing ⚠️
... and 9 more
Files with missing lines Coverage Δ
crates/pulsing-actor/src/transport/http2/mod.rs 88.67% <100.00%> (-0.42%) ⬇️
python/pulsing/core/__init__.py 90.69% <100.00%> (+7.93%) ⬆️
python/pulsing/streaming/pubsub.py 92.30% <100.00%> (ø)
python/pulsing/streaming/queue.py 93.08% <100.00%> (+0.72%) ⬆️
python/pulsing/examples/counting_game.py 0.00% <0.00%> (ø)
python/pulsing/integrations/langgraph/executor.py 0.00% <0.00%> (ø)
python/pulsing/integrations/langgraph/wrapper.py 0.00% <0.00%> (ø)
python/pulsing/core/protocol.py 96.22% <96.22%> (ø)
python/pulsing/streaming/__init__.py 90.90% <81.81%> (ø)
python/pulsing/streaming/sync_queue.py 85.71% <66.66%> (+12.98%) ⬆️
... and 13 more

... and 2 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants