<s> from . utils import NamespacedClient , query_params , _make_path , SKIP_IN_PATH <EOL> class IngestClient ( NamespacedClient ) : <EOL> @ query_params ( '<STR_LIT>' ) <EOL> def get_pipeline ( self , id , params = None ) : <EOL> """<STR_LIT>""" <EOL> if id in SKIP_IN_PATH : <EOL> raise ValueError ( "<STR_LIT>" ) <EOL> return self . transport . perform_request ( '<STR_LIT:GET>' , _make_path ( '<STR_LIT>' , <EOL> '<STR_LIT>' , id ) , params = params ) <EOL> @ query_params ( '<STR_LIT>' , '<STR_LIT>' ) <EOL> def put_pipeline ( self , id , body , params = None ) : <EOL> """<STR_LIT>""" <EOL> for param in ( id , body ) : <EOL> if param in SKIP_IN_PATH : <EOL> raise ValueError ( "<STR_LIT>" ) <EOL> return self . transport . perform_request ( '<STR_LIT>' , _make_path ( '<STR_LIT>' , <EOL> '<STR_LIT>' , id ) , params = params , body = body ) <EOL> @ query_params ( '<STR_LIT>' , '<STR_LIT>' ) <EOL> def delete_pipeline ( self , id , params = None ) : <EOL> """<STR_LIT>""" <EOL> if id in SKIP_IN_PATH : <EOL> raise ValueError ( "<STR_LIT>" ) <EOL> return self . transport . perform_request ( '<STR_LIT>' , _make_path ( '<STR_LIT>' , <EOL> '<STR_LIT>' , id ) , params = params ) <EOL> @ query_params ( '<STR_LIT>' ) <EOL> def simulate ( self , body , id = None , params = None ) : <EOL> """<STR_LIT>""" <EOL> if body in SKIP_IN_PATH : <EOL> raise ValueError ( "<STR_LIT>" ) <EOL> return self . transport . perform_request ( '<STR_LIT:GET>' , _make_path ( '<STR_LIT>' , <EOL> '<STR_LIT>' , id , '<STR_LIT>' ) , params = params , body = body ) </s>
