Commit aae5d294 authored by matthmey's avatar matthmey
Browse files

fix another bug in graph.configuration

parent ce909f1b
......@@ -258,8 +258,16 @@ def configuration(delayed, request, keys=None, default_merge=None):
for k in input_requests:
# Here we assume that we always receive the same tuple of (bound method, data, request)
# If the interface changes this will break #TODO: check for all cases
if isinstance(out[k][2], dict):
if isinstance(out[k][2], tuple):
# TODO: find a better inversion of to_task_dask()
if out[k][2][0] == dict:
my_dict = {item[0]:item[1] for item in out[k][2][1] }
out[k] = out[k][:2] + (my_dict,)
# replace the last entry
out[k] = out[k][:2] + (input_requests[k],)
# replace the last entry
out[k] = out[k][:2] + (input_requests[k],)
import permasense
import numpy as np
import pandas as pd
import pyarrow as pa
import warnings
import datetime as dt
......@@ -35,6 +35,7 @@ def test_collector():
import dask
dsk, dsk_keys = dask.base._extract_graph_and_keys([path])
path = stuett.core.configuration(path, request)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment