We've added an enrichment policy to join data among two indexes. The indexes are dynamic, hence we are running the execute policy query whenever there's an update in the source index. The problem is when there are more than one call to hit the execution policy then we're getting below error:
ApiError(429, 'es_rejected_execution_exception', 'Could not obtain lock because policy execution for [identifier-enrichment-policy] is already in progress.
Is there any way in Elasticsearch to handle the concurrent calls to enrichment policy execution?