-
-
Notifications
You must be signed in to change notification settings - Fork 1.9k
Closed
Milestone
Description
---------------------------------------------------------------------------
TypeError Traceback (most recent call last)
<ipython-input-2-197e1ec89913> in <module>()
----> 1 model = build.build_all()
/Users/henriquealves/Code/nu/lusa-model/src/lusa/build.py in build_all()
24 exceptions.CAPTURE_EXCEPTIONS = False
25
---> 26 return build_model('score_time', mordor=mordor)
/Users/henriquealves/Code/nu/lusa-model/src/lusa/build.py in build_model(score_time_col, mordor)
7
8 def build_model(score_time_col, mordor):
----> 9 return dask_cached.DaskRunner().run(train.full_pipeline(mordor, score_time_col))
10
11
/Users/henriquealves/Code/nu/common-models/src/common_models/dask_cached.pyc in run(self, obj, prev)
44 result = self.build(obj, prev)
45 with dask.set_options(get=self.get_function):
---> 46 return result.compute(num_workers=self.num_workers)
/Users/henriquealves/anaconda/envs/lusa/lib/python2.7/site-packages/dask/base.pyc in compute(self, **kwargs)
32
33 def compute(self, **kwargs):
---> 34 return compute(self, **kwargs)[0]
35
36 @classmethod
/Users/henriquealves/anaconda/envs/lusa/lib/python2.7/site-packages/dask/base.pyc in compute(*args, **kwargs)
100 for opt, val in groups.items()])
101 keys = [arg._keys() for arg in args]
--> 102 results = get(dsk, keys, **kwargs)
103 return tuple(a._finalize(a, r) for a, r in zip(args, results))
104
/Users/henriquealves/anaconda/envs/lusa/lib/python2.7/site-packages/dask/threaded.pyc in get(dsk, result, cache, num_workers, **kwargs)
55 results = get_async(pool.apply_async, len(pool._pool), dsk, result,
56 cache=cache, queue=queue, get_id=_thread_get_id,
---> 57 **kwargs)
58
59 return results
/Users/henriquealves/anaconda/envs/lusa/lib/python2.7/site-packages/dask/async.pyc in get_async(apply_async, num_workers, dsk, result, cache, queue, get_id, raise_on_exception, rerun_exceptions_locally, callbacks, **kwargs)
481 _execute_task(task, data) # Re-execute locally
482 else:
--> 483 raise(remote_exception(res, tb))
484 state['cache'][key] = res
485 finish_task(dsk, key, state, results, keyorder.get)
/Users/henriquealves/anaconda/envs/lusa/lib/python2.7/site-packages/dask/async.pyc in remote_exception(exc, tb)
585 typ = type(exc.__class__.__name__,
586 (RemoteException, type(exc)),
--> 587 {'exception_type': type(exc)})
588 exceptions[type(exc)] = typ
589 return typ(exc, tb)
TypeError: Cannot create a consistent method resolution
order (MRO) for bases AssertionError, RemoteException
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels