Cross cluster queries for mappings doesn't work use local index

Sean Sullivan · Sean Sullivan · commit b0849d04c87e · 2023-04-22T10:10:08.000-04:00
diff --git a/elastic_datashader/elastic.py b/elastic_datashader/elastic.py
@@ -167,6 +167,8 @@ def get_field_type(elastic_hosts: str, headers: Optional[str], params: Dict[str,
         timeout=900,
         headers=get_es_headers(headers, user, x_opaque_id),
     )
+    if idx.find("*:") != -1:
+        idx = idx[idx.find("*:")+2:] #when you query for mappings if it is cross cluster you don't get a mapping
     mappings = es.indices.get_field_mapping(fields=field, index=idx)
     # {'foot_prints': {'mappings': {'foot_print': {'full_name': 'foot_print', 'mapping': {'foot_print': {'type': 'geo_shape'}}}}}}
     index = list(mappings.keys())[0] # if index is my_index* it comes back as my_index

Original file line number	Diff line number	Diff line change
`@@ -167,6 +167,8 @@ def get_field_type(elastic_hosts: str, headers: Optional[str], params: Dict[str,`
`167`	`167`	`timeout=900,`
`168`	`168`	`headers=get_es_headers(headers, user, x_opaque_id),`
`169`	`169`	`)`
	`170`	`+ if idx.find("*:") != -1:`
	`171`	`+ idx = idx[idx.find("*:")+2:] #when you query for mappings if it is cross cluster you don't get a mapping`
`170`	`172`	`mappings = es.indices.get_field_mapping(fields=field, index=idx)`
`171`	`173`	`# {'foot_prints': {'mappings': {'foot_print': {'full_name': 'foot_print', 'mapping': {'foot_print': {'type': 'geo_shape'}}}}}}`
`172`	`174`	`index = list(mappings.keys())[0] # if index is my_index* it comes back as my_index`