_Y ã@s<ddlmZmZmZmZGdd„deƒZdS)é)ÚNamespacedClientÚ query_paramsÚ _make_pathÚ SKIP_IN_PATHc@sˆeZdZedƒdddd„ƒZeddƒddd„ƒZeddƒddd „ƒZed ƒddd d „ƒZdS) Ú IngestClientZmaster_timeoutNcCs%|jjdtdd|ƒd|ƒS)a ``_ :arg id: Comma separated list of pipeline ids. Wildcards supported :arg master_timeout: Explicit operation timeout for connection to master node ÚGETÚ_ingestÚpipelineÚparams)Ú transportÚperform_requestr)ÚselfÚidr ©rúD/tmp/pip-build-66pc0izb/elasticsearch/elasticsearch/client/ingest.pyÚ get_pipelines zIngestClient.get_pipelineÚtimeoutcCsZx,||fD]}|tkr tdƒ‚q W|jjdtdd|ƒd|d|ƒS)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.ÚPUTrr r Úbody)rÚ ValueErrorr r r)r rrr ÚparamrrrÚ put_pipelines  zIngestClient.put_pipelinecCs=|tkrtdƒ‚|jjdtdd|ƒd|ƒS)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'.ÚDELETErr r )rrr r r)r rr rrrÚdelete_pipeline!s  zIngestClient.delete_pipelineÚverbosecCsF|tkrtdƒ‚|jjdtdd|dƒd|d|ƒS)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'.rrr Z _simulater r)rrr r r)r rrr rrrÚsimulate0s  zIngestClient.simulate)Ú__name__Ú __module__Ú __qualname__rrrrrrrrrrs     rN)ÚutilsrrrrrrrrrÚs"