We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6c8ab14 commit f2df7c5Copy full SHA for f2df7c5
dcp/api/fetch_results.py
@@ -11,12 +11,12 @@
11
from .job_serializers import default_serializers, deserialize
12
13
def fetch_results_maker(fetch_results_js):
14
- def fetch_results(*args):
+ def fetch_results(*args, serializers=default_serializers):
15
serialized_results = dry.aio.blockify(fetch_results_js)(*args)
16
17
results = []
18
for element in serialized_results:
19
- deserialized_value = deserialize(element['value'], default_serializers)
+ deserialized_value = deserialize(element['value'], serializers)
20
slice_number = int(element['slice'])
21
22
results.append({ 'slice': slice_number, 'value': deserialized_value })
0 commit comments