File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -38,10 +38,11 @@ def _worker():
3838
3939 client = OpenAI (base_url = req .model_base_url , api_key = os .environ .get ("FIREWORKS_API_KEY" ))
4040
41- model = req .completion_params .get ("model" )
42- if not model :
43- raise ValueError ("model is required in completion_params" )
44-
41+ # Apply model_kwargs if present
42+ if req .completion_params .get ("model_kwargs" ):
43+ model_kwargs = req .completion_params ["model_kwargs" ]
44+ if isinstance (model_kwargs , dict ):
45+ completion_kwargs .update (model_kwargs )
4546 # Build up conversation over 6 turns (3 user messages + 3 assistant responses)
4647 # Convert Message objects to dicts for OpenAI API
4748 conversation_history = [{"role" : m .role , "content" : m .content } for m in req .messages ]
@@ -56,7 +57,8 @@ def _worker():
5657 logger .info (f"Turn 1-2: Sending initial completion request to model { model } " )
5758 completion = client .chat .completions .create (
5859 model = model ,
59- messages = conversation_history , # type: ignore
60+ messages = conversation_history , # type: ignore,
61+ ** completion_kwargs
6062 )
6163 assistant_message = completion .choices [0 ].message
6264 assistant_content = assistant_message .content or ""
You can’t perform that action at this time.
0 commit comments