a Y @s,ddlmZmZmZmZGdddeZdS))NamespacedClient query_params _make_path SKIP_IN_PATHc@sXeZdZedd ddZedddddZeddddd Zed dd d ZdS) IngestClientmaster_timeoutNcCs|jjdtdd||dS)a ``_ :arg id: Comma separated list of pipeline ids. Wildcards supported :arg master_timeout: Explicit operation timeout for connection to master node GET_ingestpipelineparams) transportperform_requestrselfidr rB/Users/ymaher/Downloads/lambdas_org/elasticsearch/client/ingest.py get_pipelines zIngestClient.get_pipelinetimeoutcCs:||fD]}|tvrtdq|jjdtdd|||dS)a: ``_ :arg id: Pipeline ID :arg body: The ingest definition :arg master_timeout: Explicit operation timeout for connection to master node :arg timeout: Explicit operation timeout z+Empty value passed for a required argument.PUTr r r bodyr ValueErrorr rr)rrrr paramrrr put_pipelines   zIngestClient.put_pipelinecCs*|tvrtd|jjdtdd||dS)a ``_ :arg id: Pipeline ID :arg master_timeout: Explicit operation timeout for connection to master node :arg timeout: Explicit operation timeout z0Empty value passed for a required argument 'id'.DELETEr r r rrrrrdelete_pipeline!s  zIngestClient.delete_pipelineverbosecCs.|tvrtd|jjdtdd|d||dS)a$ ``_ :arg body: The simulate definition :arg id: Pipeline ID :arg verbose: Verbose mode. Display data output for each processor in executed pipeline, default False z2Empty value passed for a required argument 'body'.rr r Z _simulaterr)rrrr rrrsimulate0s  zIngestClient.simulate)NN)N)N)NN)__name__ __module__ __qualname__rrrrr rrrrrs   rN)utilsrrrrrrrrrs