Skip to content

Feature/subprocess#57

Merged
reiase merged 6 commits intomainfrom
feature/subprocess
Mar 19, 2026
Merged

Feature/subprocess#57
reiase merged 6 commits intomainfrom
feature/subprocess

Conversation

@reiase
Copy link
Contributor

@reiase reiase commented Mar 19, 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 6 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 67.79497% with 333 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/subprocess/process.py 60.29% 54 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 ⚠️
... and 12 more
Files with missing lines Coverage Δ
crates/pulsing-actor/src/transport/http2/mod.rs 88.67% <100.00%> (-0.42%) ⬇️
python/pulsing/streaming/pubsub.py 92.30% <100.00%> (ø)
python/pulsing/streaming/queue.py 93.08% <100.00%> (+0.72%) ⬆️
python/pulsing/subprocess/__init__.py 100.00% <100.00%> (ø)
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/__init__.py 87.50% <83.33%> (+4.74%) ⬆️
python/pulsing/core/protocol.py 96.22% <96.22%> (ø)
python/pulsing/streaming/__init__.py 90.90% <81.81%> (ø)
... and 16 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.

@reiase reiase merged commit b5e54c9 into main Mar 19, 2026
25 of 26 checks passed
@reiase reiase deleted the feature/subprocess branch March 19, 2026 11:26
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