deprecated("verl.utils.reward_score.default_compute_score")

patch("builtins.open", mock_open(read_data=inputs))

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

router.post("/{job_id}/cancel")

router.post("/{job_id}/cancel")

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD, blocking=False)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD, blocking=False)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD, blocking=False)

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="actor"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="actor"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="actor"))

deprecated("verl.trainer.ppo.core_algos.compute_policy_loss_vanilla")

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="actor"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="actor"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="ref"))

tqbridge(put_data=False)

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="reward"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="reward"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="critic"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="critic"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="critic"))

router.post("")

router.post("")

register(dispatch_mode=Dispatch.ONE_TO_ALL, blocking=True)

router.get("/{job_id}/download/{file_type}")

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

click.option("--model", type=str, default=None, help="Override post-trained model path")

register(dispatch_mode=Dispatch.ALL_TO_ALL, execute_mode=Execute.RANK_ZERO)

register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO_WITH_FUNC)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD, blocking=False)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD, blocking=False)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD, blocking=False)

click.option("--output_dir", type=str, help="Output directory for generated data")

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="rollout"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="rollout"))

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

app.get("/health")

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="train"), blocking=False)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

deprecated(replacement="load_module(file_path); getattr(module, type_name)")

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

router.post("/{job_id}/generate", response_class=StreamingResponse)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

router.post("/{job_id}/refine", response_class=StreamingResponse)

router.post("/{job_id}/start", response_class=StreamingResponse)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

register(dispatch_mode=Dispatch.ONE_TO_ALL)

click.option("--output", "-o", type=click.Path(), default=None, help="Override output directory"

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="train"), blocking=False)

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="actor"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="actor"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="critic"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="critic"))

register(dispatch_mode=make_nd_compute_dataproto_dispatch_fn(mesh_name="critic"))

router.post("/{job_id}/upload", response_model=HuggingFaceUploadResponse)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)

register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)