Commit 3584b98
[classification] Migrate inference pipeline from Ray to Fray v2
Replace all Ray-specific code in classification/inference with Fray v2
equivalents. File-level parallelism now uses fray.v2.current_client().submit()
with JobRequest instead of @ray.remote + ray.wait/ray.get. The autoscaling
actor pool creates Fray actors via client.create_actor() and polls futures
with ActorFuture.result(timeout=0) instead of ray.wait. AutoClassifierRayActor
is removed; ping() and classify() are now methods on AutoClassifier directly.
ray.util.queue.Queue replaced with stdlib queue.Queue.
Fixes #4088
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>1 parent 252acf5 commit 3584b98
4 files changed
Lines changed: 210 additions & 286 deletions
File tree
- lib/marin/src/marin/processing/classification
- config
0 commit comments