data_juicer_agents.tools.apply.submit_ray_job#
submit_ray_job tool package.
- data_juicer_agents.tools.apply.submit_ray_job.submit_ray_job(*, plan_path: str, ray_address: str | None = None, timeout_seconds: int = 600, no_wait: bool = False) Dict[str, Any][source]#
Submit a dj-process job to a Ray cluster via the Ray Job API.
The plan’s recipe is written with executor_type=ray and submitted via
ray job submit -- dj-process --config <recipe>.yaml. Returns a summary dict with job_id, status, and output.