4545 AsyncUploadParamsResourceWithStreamingResponse ,
4646)
4747from ..._base_client import make_request_options
48- from ...types .data_source import DataSource
4948from ...types .datasource_list_response import DatasourceListResponse
49+ from ...types .datasource_create_response import DatasourceCreateResponse
50+ from ...types .datasource_update_response import DatasourceUpdateResponse
51+ from ...types .datasource_retrieve_response import DatasourceRetrieveResponse
52+ from ...types .datasource_create_from_file_response import DatasourceCreateFromFileResponse
5053
5154__all__ = ["DatasourcesResource" , "AsyncDatasourcesResource" ]
5255
@@ -92,7 +95,7 @@ def create(
9295 extra_query : Query | None = None ,
9396 extra_body : Body | None = None ,
9497 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
95- ) -> DataSource :
98+ ) -> DatasourceCreateResponse :
9699 """
97100 创建一个新的数据源
98101
@@ -130,7 +133,7 @@ def create(
130133 {"async_process_meta" : async_process_meta }, datasource_create_params .DatasourceCreateParams
131134 ),
132135 ),
133- cast_to = DataSource ,
136+ cast_to = DatasourceCreateResponse ,
134137 )
135138
136139 def retrieve (
@@ -143,7 +146,7 @@ def retrieve(
143146 extra_query : Query | None = None ,
144147 extra_body : Body | None = None ,
145148 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
146- ) -> DataSource :
149+ ) -> DatasourceRetrieveResponse :
147150 """
148151 根据 id 获取指定数据源
149152
@@ -163,7 +166,7 @@ def retrieve(
163166 options = make_request_options (
164167 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
165168 ),
166- cast_to = DataSource ,
169+ cast_to = DatasourceRetrieveResponse ,
167170 )
168171
169172 def update (
@@ -185,7 +188,7 @@ def update(
185188 extra_query : Query | None = None ,
186189 extra_body : Body | None = None ,
187190 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
188- ) -> DataSource :
191+ ) -> DatasourceUpdateResponse :
189192 """
190193 更新指定数据源信息
191194
@@ -237,7 +240,7 @@ def update(
237240 options = make_request_options (
238241 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
239242 ),
240- cast_to = DataSource ,
243+ cast_to = DatasourceUpdateResponse ,
241244 )
242245
243246 def list (
@@ -333,7 +336,7 @@ def create_from_file(
333336 extra_query : Query | None = None ,
334337 extra_body : Body | None = None ,
335338 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
336- ) -> DataSource :
339+ ) -> DatasourceCreateFromFileResponse :
337340 """
338341 上传文件并创建数据源
339342
@@ -369,7 +372,7 @@ def create_from_file(
369372 datasource_create_from_file_params .DatasourceCreateFromFileParams ,
370373 ),
371374 ),
372- cast_to = DataSource ,
375+ cast_to = DatasourceCreateFromFileResponse ,
373376 )
374377
375378
@@ -414,7 +417,7 @@ async def create(
414417 extra_query : Query | None = None ,
415418 extra_body : Body | None = None ,
416419 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
417- ) -> DataSource :
420+ ) -> DatasourceCreateResponse :
418421 """
419422 创建一个新的数据源
420423
@@ -452,7 +455,7 @@ async def create(
452455 {"async_process_meta" : async_process_meta }, datasource_create_params .DatasourceCreateParams
453456 ),
454457 ),
455- cast_to = DataSource ,
458+ cast_to = DatasourceCreateResponse ,
456459 )
457460
458461 async def retrieve (
@@ -465,7 +468,7 @@ async def retrieve(
465468 extra_query : Query | None = None ,
466469 extra_body : Body | None = None ,
467470 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
468- ) -> DataSource :
471+ ) -> DatasourceRetrieveResponse :
469472 """
470473 根据 id 获取指定数据源
471474
@@ -485,7 +488,7 @@ async def retrieve(
485488 options = make_request_options (
486489 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
487490 ),
488- cast_to = DataSource ,
491+ cast_to = DatasourceRetrieveResponse ,
489492 )
490493
491494 async def update (
@@ -507,7 +510,7 @@ async def update(
507510 extra_query : Query | None = None ,
508511 extra_body : Body | None = None ,
509512 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
510- ) -> DataSource :
513+ ) -> DatasourceUpdateResponse :
511514 """
512515 更新指定数据源信息
513516
@@ -559,7 +562,7 @@ async def update(
559562 options = make_request_options (
560563 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
561564 ),
562- cast_to = DataSource ,
565+ cast_to = DatasourceUpdateResponse ,
563566 )
564567
565568 async def list (
@@ -655,7 +658,7 @@ async def create_from_file(
655658 extra_query : Query | None = None ,
656659 extra_body : Body | None = None ,
657660 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
658- ) -> DataSource :
661+ ) -> DatasourceCreateFromFileResponse :
659662 """
660663 上传文件并创建数据源
661664
@@ -691,7 +694,7 @@ async def create_from_file(
691694 datasource_create_from_file_params .DatasourceCreateFromFileParams ,
692695 ),
693696 ),
694- cast_to = DataSource ,
697+ cast_to = DatasourceCreateFromFileResponse ,
695698 )
696699
697700
0 commit comments