Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 18 additions & 2 deletions trl/scripts/vllm_serve.py
Original file line number Diff line number Diff line change
Expand Up @@ -323,6 +323,23 @@ async def generate(request: GenerateRequest):
{"completion_ids": [[101, 102, 103], [201, 202, 203]]}
```
"""
all_outputs = await generate_raw(request)
completion_ids = [list(output.token_ids) for outputs in all_outputs for output in outputs.outputs]
return {"completion_ids": completion_ids}

@app.post("/generate_raw/")
async def generate_raw(request: GenerateRequest):
"""
Generates completions for the provided prompts and returns the raw list of RequestOutput objects.

Args:
request (`GenerateRequest`):
- `prompts` (list of `str`): A list of prompts (text strings) for the model to generate completions.

Returns:
`list[RequestOutput]`:
- `completion_ids` (list of list of `int`): A list of lists of token IDs for each generated completion.
"""

# Guided decoding, if enabled
if request.guided_decoding_regex is not None:
Expand All @@ -342,8 +359,7 @@ async def generate(request: GenerateRequest):
guided_decoding=guided_decoding,
)
all_outputs = llm.generate(request.prompts, sampling_params=sampling_params)
completion_ids = [list(output.token_ids) for outputs in all_outputs for output in outputs.outputs]
return {"completion_ids": completion_ids}
return all_outputs

class InitCommunicatorRequest(BaseModel):
host: str
Expand Down