aboutsummaryrefslogtreecommitdiffstats
path: root/python/api_quotes/api.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/api_quotes/api.py')
-rw-r--r--python/api_quotes/api.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/python/api_quotes/api.py b/python/api_quotes/api.py
index b9e32226..cf716f14 100644
--- a/python/api_quotes/api.py
+++ b/python/api_quotes/api.py
@@ -3,6 +3,7 @@ from urllib.parse import urljoin
import posixpath
import requests
+from itertools import groupby
from serenitas.utils.misc import get_credential_path
@@ -42,7 +43,8 @@ class MarkitAPI:
path = posixpath.join("parsing", "Quote", service)
url = urljoin(cls.base_url, path)
r = requests.get(url, params)
- return map(lowercase_keys, json.loads(r.text))
+ for msg_id, data in groupby(json.loads(r.text), key=lambda x: x["message"]):
+ yield msg_id, map(lowercase_keys, data)
@classmethod
def update_api_key(cls):