fix: RayProcess not working on Ray 2.54.0 (#214)

# Summary
Fixes a bug that occurs when using Ray `2.54.0`.

# Changes
* The latest version of Ray includes [this
change](ray-project/ray@ac15dba#diff-db449c12dfa112ed32d8fb4105900b8ca82ccdf7135f5a30d8d86e87041e27da)
in the tracing helper code. This requires a `__signature__` attribute on
actor methods. The current mechanism we have to wrap methods on the
`Component.IO` and `Component.Resource` objects returns bound methods,
which do not support `__signature__`. This PR updates the actor wrapper
utilities to mitigate the issue.
* Upgrade Ray in the lockfile.

Author: toby-coleman

plugboard/utils/ray.py

@@ -27,7 +27,12 @@ def setattr(self, key: str, value: _t.Any) -> None:
 
 
 def _call_with_name(func: _t.Callable, path: tuple[str, ...]) -> _t.Callable:
-    @wraps(func)
+    # Use __func__ for bound methods so that @wraps sets __wrapped__ to the
+    # underlying function (which supports __signature__ assignment) rather than
+    # the bound method object (which does not).
+    wraps_target = getattr(func, "__func__", func)
+
+    @wraps(wraps_target)
     def wrapper(self: _ActorWrapper, *args: _t.Any, **kwargs: _t.Any) -> _t.Callable:
         obj = self._self
         for name in path:
@@ -38,7 +43,12 @@ def wrapper(self: _ActorWrapper, *args: _t.Any, **kwargs: _t.Any) -> _t.Callable
 
 
 def _call_with_name_async(func: _t.Callable, path: tuple[str, ...]) -> _t.Callable:
-    @wraps(func)
+    # Use __func__ for bound methods so that @wraps sets __wrapped__ to the
+    # underlying function (which supports __signature__ assignment) rather than
+    # the bound method object (which does not).
+    wraps_target = getattr(func, "__func__", func)
+
+    @wraps(wraps_target)
     async def wrapper(self: _ActorWrapper, *args: _t.Any, **kwargs: _t.Any) -> _t.Callable:
         obj = self._self
         for name in path:

tests/integration/test_component_resources.py

@@ -98,6 +98,7 @@ async def test_component_resources_in_ray_process(ray_ctx: None) -> None:
         actors = list_actors(detail=True)
         component_actor = next(a for a in actors if a.name == "test")
         # Verify the component actor has the correct resources
+        assert component_actor.required_resources is not None
         assert component_actor.required_resources["CPU"] == 1.0
         assert component_actor.required_resources["memory"] == 1.0 * 1024 * 1024
         await process.run()