Skip to content

Commit 64af103

Browse files
committed
feat: added files ids support
1 parent a2ee0cd commit 64af103

File tree

2 files changed

+21
-1
lines changed

2 files changed

+21
-1
lines changed

orq_ai_sdk/api_resources/async_deployments.py

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -331,6 +331,7 @@ def __validate_params(
331331
messages: Optional[List[Dict[str, Any]]] = None,
332332
extra_params: Optional[Dict[str, Any]] = None,
333333
invoke_options: Optional[DeploymentInvokeOptions] = None,
334+
file_ids: Optional[List[str]] = None,
334335
):
335336

336337
self.body_params = {}
@@ -363,6 +364,9 @@ def __validate_params(
363364
if invoke_options is not None:
364365
self.body_params["invoke_options"] = invoke_options
365366

367+
if file_ids is not None:
368+
self.body_params["file_ids"] = file_ids
369+
366370
async def get_config(self, key: str, context=None, inputs=None, metadata=None):
367371
self.__validate_params(
368372
key=key, context=context, inputs=inputs, metadata=metadata
@@ -390,7 +394,8 @@ async def invoke(
390394
prefix_messages=None,
391395
messages=None,
392396
extra_params=None,
393-
invoke_options=None,
397+
invoke_options: Optional[DeploymentInvokeOptions] = None,
398+
file_ids: Optional[List[str]] = None,
394399
):
395400
"""
396401
Invokes a deployment with the specified key using the async HTTP client.
@@ -404,6 +409,7 @@ async def invoke(
404409
:param messages (list, optional): The messages to send to the LLM with the messages template. Defaults to None.
405410
:param extra_params (dict, optional): Additional parameters to include with the invocation. Defaults to None.
406411
:param invoke_options (dict, optional): Options for the deployment invocation. Defaults to None.
412+
:param file_ids (list, optional): A list of file ids to include with the invocation. Defaults to None.
407413
408414
Returns:
409415
`Deployment`: The invoked deployment.
@@ -420,6 +426,7 @@ async def invoke(
420426
messages=messages,
421427
extra_params=extra_params,
422428
invoke_options=invoke_options,
429+
file_ids=file_ids,
423430
)
424431

425432
response = await post_async(
@@ -445,6 +452,7 @@ async def invoke_with_stream(
445452
messages=None,
446453
extra_params=None,
447454
invoke_options: Optional[DeploymentInvokeOptions] = None,
455+
file_ids: Optional[List[str]] = None,
448456
):
449457
"""
450458
Invokes a deployment with the specified key using the async HTTP client and stream the response.
@@ -458,6 +466,7 @@ async def invoke_with_stream(
458466
:param messages (Optional): The messages parameter. Defaults to None.
459467
:param extra_params (dict, optional): Additional parameters to include with the invocation. Defaults to None.
460468
:param invoke_options (dict, optional): Options for the deployment invocation. Defaults to None.
469+
:param file_ids (list, optional): A list of file ids to include with the invocation. Defaults to None.
461470
462471
Yields:
463472
Deployment: A deployment object.
@@ -475,6 +484,7 @@ async def invoke_with_stream(
475484
messages=messages,
476485
extra_params=extra_params,
477486
invoke_options=invoke_options,
487+
file_ids=file_ids,
478488
)
479489

480490
async for response in stream_async(

orq_ai_sdk/api_resources/deployments.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -330,6 +330,7 @@ def __validate_params(
330330
messages: Optional[List[Dict[str, Any]]] = None,
331331
extra_params: Optional[Dict[str, Any]] = None,
332332
invoke_options: Optional[DeploymentInvokeOptions] = None,
333+
file_ids: Optional[List[str]] = None,
333334
):
334335

335336
self.body_params = {}
@@ -362,6 +363,9 @@ def __validate_params(
362363
if invoke_options is not None:
363364
self.body_params["invoke_options"] = invoke_options
364365

366+
if file_ids is not None:
367+
self.body_params["file_ids"] = file_ids
368+
365369
def get_config(self, key: str, context=None, inputs=None, metadata=None):
366370
self.__validate_params(
367371
key=key, context=context, inputs=inputs, metadata=metadata
@@ -390,6 +394,7 @@ def invoke(
390394
messages=None,
391395
extra_params=None,
392396
invoke_options: Optional[DeploymentInvokeOptions] = None,
397+
file_ids: Optional[List[str]] = None,
393398
):
394399
"""
395400
Invokes a deployment with the specified key.
@@ -403,6 +408,7 @@ def invoke(
403408
:param messages (list, optional): The messages to send to the LLM with the messages template. Defaults to None.
404409
:param extra_params (dict, optional): Additional parameters to include with the invocation. Defaults to None.
405410
:param invoke_options (dict, optional): Options for the deployment invocation. Defaults to None.
411+
:param file_ids (list, optional): A list of file ids to include with the invocation. Defaults to None.
406412
407413
Returns:
408414
`Deployment`: The invoked deployment.
@@ -419,6 +425,7 @@ def invoke(
419425
messages=messages,
420426
extra_params=extra_params,
421427
invoke_options=invoke_options,
428+
file_ids=file_ids,
422429
)
423430

424431
response = post(
@@ -444,6 +451,7 @@ def invoke_with_stream(
444451
messages=None,
445452
extra_params=None,
446453
invoke_options: Optional[DeploymentInvokeOptions] = None,
454+
file_ids: Optional[List[str]] = None,
447455
):
448456
"""
449457
Invokes a deployment with the specified key and stream the response.
@@ -459,6 +467,7 @@ def invoke_with_stream(
459467
:param messages (list, optional): The messages to send to the LLM with the template. Defaults to None.
460468
:param extra_params (dict, optional): Additional parameters to include with the invocation. Defaults to None.
461469
:param invoke_options (dict, optional): Options for the deployment invocation. Defaults to None.
470+
:param file_ids (list, optional): A list of file ids to include with the invocation. Defaults to None.
462471
463472
Returns:
464473
`Deployment`: The invoked deployment.
@@ -475,6 +484,7 @@ def invoke_with_stream(
475484
messages=messages,
476485
extra_params=extra_params,
477486
invoke_options=invoke_options,
487+
file_ids=file_ids,
478488
)
479489

480490
for response in stream(

0 commit comments

Comments
 (0)