@@ -906,6 +906,103 @@ def create_snapshot_with_http_info(self, body, **kwargs): # noqa: E501
906906 _request_timeout = params .get ('_request_timeout' ),
907907 collection_formats = collection_formats )
908908
909+ def delete_data_flow (self , body , ** kwargs ): # noqa: E501
910+ """delete_data_flow # noqa: E501
911+
912+ This method makes a synchronous HTTP request by default. To make an
913+ asynchronous HTTP request, please pass async_req=True
914+ >>> thread = api.delete_data_flow(body, async_req=True)
915+ >>> result = thread.get()
916+
917+ :param async_req bool
918+ :param DeleteDataFlowRequest body: (required)
919+ :return: DeleteDataFlowResponse
920+ If the method is called asynchronously,
921+ returns the request thread.
922+ """
923+ kwargs ['_return_http_data_only' ] = True
924+ if kwargs .get ('async_req' ):
925+ return self .delete_data_flow_with_http_info (body , ** kwargs ) # noqa: E501
926+ else :
927+ (data ) = self .delete_data_flow_with_http_info (body , ** kwargs ) # noqa: E501
928+ return data
929+
930+ def delete_data_flow_with_http_info (self , body , ** kwargs ): # noqa: E501
931+ """delete_data_flow # noqa: E501
932+
933+ This method makes a synchronous HTTP request by default. To make an
934+ asynchronous HTTP request, please pass async_req=True
935+ >>> thread = api.delete_data_flow_with_http_info(body, async_req=True)
936+ >>> result = thread.get()
937+
938+ :param async_req bool
939+ :param DeleteDataFlowRequest body: (required)
940+ :return: DeleteDataFlowResponse
941+ If the method is called asynchronously,
942+ returns the request thread.
943+ """
944+
945+ all_params = ['body' ] # noqa: E501
946+ all_params .append ('async_req' )
947+ all_params .append ('_return_http_data_only' )
948+ all_params .append ('_preload_content' )
949+ all_params .append ('_request_timeout' )
950+
951+ params = locals ()
952+ for key , val in six .iteritems (params ['kwargs' ]):
953+ if key not in all_params :
954+ raise TypeError (
955+ "Got an unexpected keyword argument '%s'"
956+ " to method delete_data_flow" % key
957+ )
958+ params [key ] = val
959+ del params ['kwargs' ]
960+ # verify the required parameter 'body' is set
961+ if self .api_client .client_side_validation and ('body' not in params or
962+ params ['body' ] is None ): # noqa: E501
963+ raise ValueError ("Missing the required parameter `body` when calling `delete_data_flow`" ) # noqa: E501
964+
965+ collection_formats = {}
966+
967+ path_params = {}
968+
969+ query_params = []
970+
971+ header_params = {}
972+
973+ form_params = []
974+ local_var_files = {}
975+
976+ body_params = None
977+ if 'body' in params :
978+ body_params = params ['body' ]
979+ # HTTP header `Accept`
980+ header_params ['Accept' ] = self .api_client .select_header_accept (
981+ ['application/json' ]) # noqa: E501
982+
983+ # HTTP header `Content-Type`
984+ header_params ['Content-Type' ] = self .api_client .select_header_content_type ( # noqa: E501
985+ ['application/json' ]) # noqa: E501
986+
987+ # Authentication setting
988+ auth_settings = ['volcengineSign' ] # noqa: E501
989+
990+ return self .api_client .call_api (
991+ '/DeleteDataFlow/2022-01-01/filenas/post/application_json/' , 'POST' ,
992+ path_params ,
993+ query_params ,
994+ header_params ,
995+ body = body_params ,
996+ post_params = form_params ,
997+ files = local_var_files ,
998+ response_type = 'DeleteDataFlowResponse' , # noqa: E501
999+ auth_settings = auth_settings ,
1000+ async_req = params .get ('async_req' ),
1001+ _return_http_data_only = params .get ('_return_http_data_only' ),
1002+ _preload_content = params .get ('_preload_content' , True ),
1003+ _request_timeout = params .get ('_request_timeout' ),
1004+ collection_formats = collection_formats )
1005+
9091006 def delete_data_flow_task (self , body , ** kwargs ): # noqa: E501
9101007 """delete_data_flow_task # noqa: E501
9111008
0 commit comments