1111 dataset_create_params ,
1212 dataset_update_params ,
1313 dataset_insert_entry_params ,
14- dataset_upload_jsonl_params ,
1514 dataset_generate_schema_params ,
1615 dataset_generate_dataset_params ,
1716 dataset_generate_validators_params ,
3837from ...types .dataset import Dataset
3938from ...types .dataset_list_response import DatasetListResponse
4039from ...types .dataset_delete_response import DatasetDeleteResponse
41- from ...types .dataset_upload_jsonl_response import DatasetUploadJSONLResponse
40+ from ...types .dataset_insert_entry_response import DatasetInsertEntryResponse
4241from ...types .dataset_generate_schema_response import DatasetGenerateSchemaResponse
4342from ...types .dataset_generate_dataset_response import DatasetGenerateDatasetResponse
4443from ...types .dataset_generate_validators_response import DatasetGenerateValidatorsResponse
@@ -472,7 +471,7 @@ def insert_entry(
472471 extra_query : Query | None = None ,
473472 extra_body : Body | None = None ,
474473 timeout : float | httpx .Timeout | None | NotGiven = not_given ,
475- ) -> str :
474+ ) -> DatasetInsertEntryResponse :
476475 """
477476 Insert an entry into a dataset.
478477
@@ -493,53 +492,7 @@ def insert_entry(
493492 options = make_request_options (
494493 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
495494 ),
496- cast_to = str ,
497- )
498-
499- def upload_jsonl (
500- self ,
501- dataset_id : str ,
502- * ,
503- file : FileTypes ,
504- # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
505- # The extra values given here take precedence over values defined on the client or passed to this method.
506- extra_headers : Headers | None = None ,
507- extra_query : Query | None = None ,
508- extra_body : Body | None = None ,
509- timeout : float | httpx .Timeout | None | NotGiven = not_given ,
510- ) -> DatasetUploadJSONLResponse :
511- """
512- Upload a JSONL file to a dataset.
513-
514- Accepts a JSONL (JSON Lines) file where each line is a valid JSON object. Each
515- entry is stored in S3 and a JSON schema is automatically generated from all
516- entries using GenSON. The dataset status will be updated to READY.
517-
518- Args:
519- extra_headers: Send extra headers
520-
521- extra_query: Add additional query parameters to the request
522-
523- extra_body: Add additional JSON properties to the request
524-
525- timeout: Override the client-level default timeout for this request, in seconds
526- """
527- if not dataset_id :
528- raise ValueError (f"Expected a non-empty value for `dataset_id` but received { dataset_id !r} " )
529- body = deepcopy_minimal ({"file" : file })
530- files = extract_files (cast (Mapping [str , object ], body ), paths = [["file" ]])
531- # It should be noted that the actual Content-Type header that will be
532- # sent to the server will contain a `boundary` parameter, e.g.
533- # multipart/form-data; boundary=---abc--
534- extra_headers = {"Content-Type" : "multipart/form-data" , ** (extra_headers or {})}
535- return self ._post (
536- f"/datasets/{ dataset_id } /upload-jsonl" ,
537- body = maybe_transform (body , dataset_upload_jsonl_params .DatasetUploadJSONLParams ),
538- files = files ,
539- options = make_request_options (
540- extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
541- ),
542- cast_to = DatasetUploadJSONLResponse ,
495+ cast_to = DatasetInsertEntryResponse ,
543496 )
544497
545498
@@ -971,7 +924,7 @@ async def insert_entry(
971924 extra_query : Query | None = None ,
972925 extra_body : Body | None = None ,
973926 timeout : float | httpx .Timeout | None | NotGiven = not_given ,
974- ) -> str :
927+ ) -> DatasetInsertEntryResponse :
975928 """
976929 Insert an entry into a dataset.
977930
@@ -992,53 +945,7 @@ async def insert_entry(
992945 options = make_request_options (
993946 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
994947 ),
995- cast_to = str ,
996- )
997-
998- async def upload_jsonl (
999- self ,
1000- dataset_id : str ,
1001- * ,
1002- file : FileTypes ,
1003- # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
1004- # The extra values given here take precedence over values defined on the client or passed to this method.
1005- extra_headers : Headers | None = None ,
1006- extra_query : Query | None = None ,
1007- extra_body : Body | None = None ,
1008- timeout : float | httpx .Timeout | None | NotGiven = not_given ,
1009- ) -> DatasetUploadJSONLResponse :
1010- """
1011- Upload a JSONL file to a dataset.
1012-
1013- Accepts a JSONL (JSON Lines) file where each line is a valid JSON object. Each
1014- entry is stored in S3 and a JSON schema is automatically generated from all
1015- entries using GenSON. The dataset status will be updated to READY.
1016-
1017- Args:
1018- extra_headers: Send extra headers
1019-
1020- extra_query: Add additional query parameters to the request
1021-
1022- extra_body: Add additional JSON properties to the request
1023-
1024- timeout: Override the client-level default timeout for this request, in seconds
1025- """
1026- if not dataset_id :
1027- raise ValueError (f"Expected a non-empty value for `dataset_id` but received { dataset_id !r} " )
1028- body = deepcopy_minimal ({"file" : file })
1029- files = extract_files (cast (Mapping [str , object ], body ), paths = [["file" ]])
1030- # It should be noted that the actual Content-Type header that will be
1031- # sent to the server will contain a `boundary` parameter, e.g.
1032- # multipart/form-data; boundary=---abc--
1033- extra_headers = {"Content-Type" : "multipart/form-data" , ** (extra_headers or {})}
1034- return await self ._post (
1035- f"/datasets/{ dataset_id } /upload-jsonl" ,
1036- body = await async_maybe_transform (body , dataset_upload_jsonl_params .DatasetUploadJSONLParams ),
1037- files = files ,
1038- options = make_request_options (
1039- extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
1040- ),
1041- cast_to = DatasetUploadJSONLResponse ,
948+ cast_to = DatasetInsertEntryResponse ,
1042949 )
1043950
1044951
@@ -1076,9 +983,6 @@ def __init__(self, datasets: DatasetsResource) -> None:
1076983 self .insert_entry = to_raw_response_wrapper (
1077984 datasets .insert_entry ,
1078985 )
1079- self .upload_jsonl = to_raw_response_wrapper (
1080- datasets .upload_jsonl ,
1081- )
1082986
1083987 @cached_property
1084988 def generations (self ) -> GenerationsResourceWithRawResponse :
@@ -1119,9 +1023,6 @@ def __init__(self, datasets: AsyncDatasetsResource) -> None:
11191023 self .insert_entry = async_to_raw_response_wrapper (
11201024 datasets .insert_entry ,
11211025 )
1122- self .upload_jsonl = async_to_raw_response_wrapper (
1123- datasets .upload_jsonl ,
1124- )
11251026
11261027 @cached_property
11271028 def generations (self ) -> AsyncGenerationsResourceWithRawResponse :
@@ -1162,9 +1063,6 @@ def __init__(self, datasets: DatasetsResource) -> None:
11621063 self .insert_entry = to_streamed_response_wrapper (
11631064 datasets .insert_entry ,
11641065 )
1165- self .upload_jsonl = to_streamed_response_wrapper (
1166- datasets .upload_jsonl ,
1167- )
11681066
11691067 @cached_property
11701068 def generations (self ) -> GenerationsResourceWithStreamingResponse :
@@ -1205,9 +1103,6 @@ def __init__(self, datasets: AsyncDatasetsResource) -> None:
12051103 self .insert_entry = async_to_streamed_response_wrapper (
12061104 datasets .insert_entry ,
12071105 )
1208- self .upload_jsonl = async_to_streamed_response_wrapper (
1209- datasets .upload_jsonl ,
1210- )
12111106
12121107 @cached_property
12131108 def generations (self ) -> AsyncGenerationsResourceWithStreamingResponse :
0 commit comments