Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Xuekai-Zhu/FlowRL
/ endpoints
Endpoints
120 in github.com/Xuekai-Zhu/FlowRL
⨍
Functions
4,141
◇
Types & classes
610
↳
Endpoints
120
Route
_default_compute_score
deprecated("verl.utils.reward_score.default_compute_score")
verl_Test/verl/utils/reward_score/__init__.py:None
Route
_default_compute_score
deprecated("verl.utils.reward_score.default_compute_score")
verl_FlowRL/verl/utils/reward_score/__init__.py:None
Route
_inner_call_method
patch('builtins.open', mock_open(read_data=inputs))
verl_Test/rllm/rewards/code_utils/codeforces.py:None
Route
_inner_call_method
patch("builtins.open", mock_open(read_data=inputs))
verl_Test/rllm/rewards/code_utils/livecodebench.py:None
Route
_inner_call_method
patch('builtins.open', mock_open(read_data=inputs))
verl_Test/rllm/rewards/code_utils/taco.py:None
Route
_inner_call_method
patch("builtins.open", mock_open(read_data=inputs))
verl_Test/verl/utils/reward_score/prime_code/testing_util.py:None
Route
_inner_call_method
patch('builtins.open', mock_open(read_data=inputs))
verl_FlowRL/rllm/rewards/code_utils/codeforces.py:None
Route
_inner_call_method
patch("builtins.open", mock_open(read_data=inputs))
verl_FlowRL/rllm/rewards/code_utils/livecodebench.py:None
Route
_inner_call_method
patch('builtins.open', mock_open(read_data=inputs))
verl_FlowRL/rllm/rewards/code_utils/taco.py:None
Route
_inner_call_method
patch("builtins.open", mock_open(read_data=inputs))
verl_FlowRL/verl/utils/reward_score/prime_code/testing_util.py:None
Route
add
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/tests/ray_cpu/test_fused_workers.py:None
Route
add
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/tests/ray_cpu/test_auto_padding.py:None
Route
add
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/tests/ray_gpu/test_colocated_workers_fused.py:None
Route
add
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/tests/ray_gpu/test_colocated_workers.py:None
Route
async_dp_compute
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO, blocking=False)
verl_FlowRL/tests/ray_cpu/test_decorator.py:None
Route
compute_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/recipe/spin/fsdp_workers.py:None
Route
compute_log_prob
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_Test/verl/workers/megatron_workers.py:None
Route
compute_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/verl/workers/fsdp_workers.py:None
Route
compute_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/recipe/spin/fsdp_workers.py:None
Route
compute_log_prob
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
compute_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
compute_ref_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/recipe/spin/fsdp_workers.py:None
Route
compute_ref_log_prob
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_Test/verl/workers/megatron_workers.py:None
Route
compute_ref_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/verl/workers/fsdp_workers.py:None
Route
compute_ref_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/recipe/spin/fsdp_workers.py:None
Route
compute_ref_log_prob
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
compute_ref_log_prob
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/recipe/spin/fsdp_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/recipe/prime/prime_fsdp_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_Test/verl/workers/megatron_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/verl/workers/fsdp_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/recipe/spin/fsdp_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/recipe/prime/prime_fsdp_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
compute_rm_score
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
compute_values
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_Test/verl/workers/megatron_workers.py:None
Route
compute_values
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/verl/workers/fsdp_workers.py:None
Route
compute_values
register(dispatch_mode=Dispatch.MEGATRON_COMPUTE_PROTO)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
compute_values
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
do_nothing
register(dispatch_mode=Dispatch.DP_COMPUTE, blocking=False)
verl_FlowRL/tests/ray_gpu/test_data_transfer.py:None
Route
dp_compute
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/tests/ray_cpu/test_decorator.py:None
Route
execute_func_rank_zero
register(dispatch_mode=Dispatch.ALL_TO_ALL, execute_mode=Execute.RANK_ZERO)
verl_Test/verl/single_controller/base/worker.py:None
Route
execute_func_rank_zero
register(dispatch_mode=Dispatch.ALL_TO_ALL, execute_mode=Execute.RANK_ZERO)
verl_FlowRL/verl/single_controller/base/worker.py:None
Route
execute_method
register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)
verl_Test/verl/workers/fsdp_workers.py:None
Route
execute_method
register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
execute_with_func_generator
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO_WITH_FUNC)
verl_Test/verl/single_controller/base/worker.py:None
Route
execute_with_func_generator
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO_WITH_FUNC)
verl_FlowRL/verl/single_controller/base/worker.py:None
Route
foo
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/tests/ray_cpu/test_fused_workers.py:None
Route
foo
register(dispatch_mode=Dispatch.ONE_TO_ALL, blocking=False)
verl_FlowRL/tests/ray_cpu/check_worker_alive/main.py:None
Route
foo_all_to_all
register(Dispatch.ALL_TO_ALL, blocking=False)
verl_FlowRL/tests/ray_gpu/test_worker_group_basics.py:None
Route
foo_custom
register(dispatch_mode={"dispatch_fn": two_to_all_dispatch_fn, "collect_fn": collect_all_to_all})
verl_FlowRL/tests/ray_gpu/test_worker_group_basics.py:None
Route
foo_one_to_all
register(Dispatch.ONE_TO_ALL, blocking=False)
verl_FlowRL/tests/ray_gpu/test_worker_group_basics.py:None
Route
foo_rank_zero
register(dispatch_mode=Dispatch.ALL_TO_ALL, execute_mode=Execute.RANK_ZERO)
verl_FlowRL/tests/ray_gpu/test_worker_group_basics.py:None
Route
generate_sequences
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/verl/workers/megatron_workers.py:None
Route
generate_sequences
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_Test/verl/workers/fsdp_workers.py:None
Route
generate_sequences
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
generate_sequences
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/recipe/spin/fsdp_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/recipe/prime/prime_fsdp_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/recipe/sppo/sppo_worker.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/verl/workers/megatron_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/verl/workers/fsdp_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/recipe/spin/fsdp_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/recipe/prime/prime_fsdp_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/recipe/sppo/sppo_worker.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/tests/ray_gpu/detached_worker/server.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
init_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
load_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/recipe/prime/prime_fsdp_workers.py:None
Route
load_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/verl/workers/megatron_workers.py:None
Route
load_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/verl/workers/fsdp_workers.py:None
Route
load_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/recipe/prime/prime_fsdp_workers.py:None
Route
load_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
load_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
load_pretrained_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/verl/workers/megatron_workers.py:None
Route
load_pretrained_model
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
offload
register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)
verl_Test/verl/workers/fsdp_workers.py:None
Route
offload
register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
resume
register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)
verl_Test/verl/workers/fsdp_workers.py:None
Route
resume
register(dispatch_mode=Dispatch.DIRECT_ROLLOUT_METHOD)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
retrieve_endpoint
app.post("/retrieve")
verl_Test/examples/sglang_multiturn/search_r1_like/local_dense_retriever/retrieval_server.py:None
Route
retrieve_endpoint
app.post("/retrieve")
verl_FlowRL/examples/sglang_multiturn/search_r1_like/local_dense_retriever/retrieval_server.py:None
Route
save_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/recipe/prime/prime_fsdp_workers.py:None
Route
save_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/verl/workers/megatron_workers.py:None
Route
save_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_Test/verl/workers/fsdp_workers.py:None
Route
save_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/recipe/prime/prime_fsdp_workers.py:None
Route
save_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/verl/workers/megatron_workers.py:None
Route
save_checkpoint
register(dispatch_mode=Dispatch.ONE_TO_ALL)
verl_FlowRL/verl/workers/fsdp_workers.py:None
Route
sub
register(dispatch_mode=Dispatch.ALL_TO_ALL)
verl_FlowRL/tests/ray_cpu/test_fused_workers.py:None
Route
sub
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/tests/ray_gpu/test_colocated_workers_fused.py:None
Route
sub
register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
verl_FlowRL/tests/ray_gpu/test_colocated_workers.py:None
Route
test_compute_timing_metrics
patch("verl.trainer.ppo.metric_utils._compute_response_info")
verl_FlowRL/tests/trainer/ppo/test_metric_utils.py:None
Route
test_continuous_score_consistency
pytest.mark.skipif(not os.environ.get("SANDBOX_FUSION_URL"), reason="SANDBOX_FUSION_URL environment variable n
verl_FlowRL/tests/sandbox/test_sandbox.py:None
Route
test_init_engine
patch("verl.workers.rollout.sglang_rollout.async_sglang_server.ray.util.list_named_actors")
verl_FlowRL/tests/workers/rollout/test_async_sglang_server.py:None
Route
test_over_size_case
patch.object(SGLangRollout, "_init_distributed_env", return_value=None)
verl_FlowRL/tests/workers/rollout/test_sglang_async_rollout_sf_tools.py:None
Route
test_over_size_case
patch.object(SGLangRollout, "_init_distributed_env", return_value=None)
verl_FlowRL/tests/workers/rollout/test_sglang_async_rollout_search_tools.py:None
Route
test_prime_code_sandbox_fusion
pytest.mark.skipif(not os.environ.get("SANDBOX_FUSION_URL"), reason="SANDBOX_FUSION_URL environment variable n
verl_FlowRL/tests/sandbox/test_sandbox.py:None
Route
test_rollout_req_creation
patch.object(SGLangRollout, "_init_distributed_env", return_value=None)
verl_FlowRL/tests/workers/rollout/test_sglang_async_rollout_sf_tools.py:None
Route
test_rollout_req_creation
patch.object(SGLangRollout, "_init_distributed_env", return_value=None)
verl_FlowRL/tests/workers/rollout/test_sglang_async_rollout_search_tools.py:None
Route
test_tool_call_basic_case
patch.object(SGLangRollout, "_init_distributed_env", return_value=None)
verl_FlowRL/tests/workers/rollout/test_sglang_async_rollout_sf_tools.py:None
next →
1–100 of 120, ranked by callers