Merge pull request #61 from lscheinkman/fix_elastic_logger

Update elastic_logger to be compatible with latest pandas
numenta · Sep 12, 2019 · e1c518d · e1c518d
2 parents 67261bc + b145750
commit e1c518d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/nupic/research/support/elastic_logger.py b/nupic/research/support/elastic_logger.py
@@ -26,7 +26,7 @@
 from elasticsearch.client.xpack import SqlClient
 from elasticsearch.helpers import BulkIndexError
 from pandas import DataFrame
-from pandas.io.json.normalize import nested_to_record
+from pandas.io.json import json_normalize
 from ray.tune.logger import Logger
 
 
@@ -178,7 +178,7 @@ def elastic_dsl(client, dsl, index, **kwargs):
     data = []
     for row in response:
         # Normalize nested dicts in '_source' such as 'config' or 'git'
-        source = nested_to_record(row["_source"]) if "_source" in row else {}
+        source = json_normalize(row["_source"]) if "_source" in row else {}
 
         # Squeeze scalar fields returned as arrays in the response by the search API
         fields = row.get("fields", {})