data_juicer_agents.tools.apply.submit_ray_job.logic module

Pure logic for submit_ray_job — runtime-agnostic.

data_juicer_agents.tools.apply.submit_ray_job.logic.submit_ray_job(*, plan_path: str, ray_address: str | None = None, timeout_seconds: int = 600, no_wait: bool = False) → Dict[str, Any]

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.