U Ec_T@s,ddlmZmZmZmZGdddeZdS))NamespacedClient query_params _make_path SKIP_IN_PATHc@s^eZdZed ddZeddddZedddZedd d Zedd d ZdS) EnrichClientNcCs,|tkrtd|jjdtdd|||dS)z Deletes an existing enrich policy and its enrich index. ``_ :arg name: The name of the enrich policy 2Empty value passed for a required argument 'name'.DELETE_enrichpolicyparamsheadersr ValueError transportperform_requestrselfnamer r rB/tmp/pip-target-m1bursmm/lib/python/elasticsearch/client/enrich.py delete_policys zEnrichClient.delete_policyZwait_for_completioncCs.|tkrtd|jjdtdd|d||dS)aa Creates the enrich index for an existing enrich policy. ``_ :arg name: The name of the enrich policy :arg wait_for_completion: Should the request should block until the execution is complete. Default: True rPUTr r Z_executer rrrrrexecute_policy(s  zEnrichClient.execute_policycCs|jjdtdd|||dS)z Gets information about an enrich policy. ``_ :arg name: A comma-separated list of enrich policy names GETr r r )rrrrrrr get_policy<s  zEnrichClient.get_policycCs<||fD]}|tkrtdq|jjdtdd||||dS)z Creates a new enrich policy. ``_ :arg name: The name of the enrich policy :arg body: The enrich policy to register z+Empty value passed for a required argument.rr r )r r bodyr)rrrr r paramrrr put_policyHs   zEnrichClient.put_policycCs|jjdd||dS)z Gets enrich coordinator statistics and information about enrich policies that are currently executing. ``_ rz/_enrich/_statsr )rr)rr r rrrstats]s zEnrichClient.stats)NN)NN)NNN)NN)NN) __name__ __module__ __qualname__rrrrrrrrrrrs    rN)utilsrrrrrrrrrs