2323)
2424from ..._base_client import make_request_options
2525from ...types .datasources import meta_create_params , meta_update_params
26- from ...types .datasources .meta_retrieve_response import MetaRetrieveResponse
26+ from ...types .datasources .meta import Meta
2727
2828__all__ = ["MetaResource" , "AsyncMetaResource" ]
2929
@@ -156,7 +156,7 @@ def retrieve(
156156 extra_query : Query | None = None ,
157157 extra_body : Body | None = None ,
158158 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
159- ) -> MetaRetrieveResponse :
159+ ) -> Meta :
160160 """
161161 从数据源中获取最新的元数据
162162
@@ -176,7 +176,7 @@ def retrieve(
176176 options = make_request_options (
177177 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
178178 ),
179- cast_to = MetaRetrieveResponse ,
179+ cast_to = Meta ,
180180 )
181181
182182 @overload
@@ -269,6 +269,39 @@ def update(
269269 cast_to = object ,
270270 )
271271
272+ def delete (
273+ self ,
274+ datasource_id : str ,
275+ * ,
276+ # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
277+ # The extra values given here take precedence over values defined on the client or passed to this method.
278+ extra_headers : Headers | None = None ,
279+ extra_query : Query | None = None ,
280+ extra_body : Body | None = None ,
281+ timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
282+ ) -> object :
283+ """
284+ Delete Datasource Metadata
285+
286+ Args:
287+ extra_headers: Send extra headers
288+
289+ extra_query: Add additional query parameters to the request
290+
291+ extra_body: Add additional JSON properties to the request
292+
293+ timeout: Override the client-level default timeout for this request, in seconds
294+ """
295+ if not datasource_id :
296+ raise ValueError (f"Expected a non-empty value for `datasource_id` but received { datasource_id !r} " )
297+ return self ._delete (
298+ f"/datasources/{ datasource_id } /meta" ,
299+ options = make_request_options (
300+ extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
301+ ),
302+ cast_to = object ,
303+ )
304+
272305
273306class AsyncMetaResource (AsyncAPIResource ):
274307 @cached_property
@@ -398,7 +431,7 @@ async def retrieve(
398431 extra_query : Query | None = None ,
399432 extra_body : Body | None = None ,
400433 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
401- ) -> MetaRetrieveResponse :
434+ ) -> Meta :
402435 """
403436 从数据源中获取最新的元数据
404437
@@ -418,7 +451,7 @@ async def retrieve(
418451 options = make_request_options (
419452 extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
420453 ),
421- cast_to = MetaRetrieveResponse ,
454+ cast_to = Meta ,
422455 )
423456
424457 @overload
@@ -511,6 +544,39 @@ async def update(
511544 cast_to = object ,
512545 )
513546
547+ async def delete (
548+ self ,
549+ datasource_id : str ,
550+ * ,
551+ # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
552+ # The extra values given here take precedence over values defined on the client or passed to this method.
553+ extra_headers : Headers | None = None ,
554+ extra_query : Query | None = None ,
555+ extra_body : Body | None = None ,
556+ timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
557+ ) -> object :
558+ """
559+ Delete Datasource Metadata
560+
561+ Args:
562+ extra_headers: Send extra headers
563+
564+ extra_query: Add additional query parameters to the request
565+
566+ extra_body: Add additional JSON properties to the request
567+
568+ timeout: Override the client-level default timeout for this request, in seconds
569+ """
570+ if not datasource_id :
571+ raise ValueError (f"Expected a non-empty value for `datasource_id` but received { datasource_id !r} " )
572+ return await self ._delete (
573+ f"/datasources/{ datasource_id } /meta" ,
574+ options = make_request_options (
575+ extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
576+ ),
577+ cast_to = object ,
578+ )
579+
514580
515581class MetaResourceWithRawResponse :
516582 def __init__ (self , meta : MetaResource ) -> None :
@@ -525,6 +591,9 @@ def __init__(self, meta: MetaResource) -> None:
525591 self .update = to_raw_response_wrapper (
526592 meta .update ,
527593 )
594+ self .delete = to_raw_response_wrapper (
595+ meta .delete ,
596+ )
528597
529598
530599class AsyncMetaResourceWithRawResponse :
@@ -540,6 +609,9 @@ def __init__(self, meta: AsyncMetaResource) -> None:
540609 self .update = async_to_raw_response_wrapper (
541610 meta .update ,
542611 )
612+ self .delete = async_to_raw_response_wrapper (
613+ meta .delete ,
614+ )
543615
544616
545617class MetaResourceWithStreamingResponse :
@@ -555,6 +627,9 @@ def __init__(self, meta: MetaResource) -> None:
555627 self .update = to_streamed_response_wrapper (
556628 meta .update ,
557629 )
630+ self .delete = to_streamed_response_wrapper (
631+ meta .delete ,
632+ )
558633
559634
560635class AsyncMetaResourceWithStreamingResponse :
@@ -570,3 +645,6 @@ def __init__(self, meta: AsyncMetaResource) -> None:
570645 self .update = async_to_streamed_response_wrapper (
571646 meta .update ,
572647 )
648+ self .delete = async_to_streamed_response_wrapper (
649+ meta .delete ,
650+ )
0 commit comments