Skip to content

dask.async.remote_exception fails for some exception types #894

@hcarvalhoalves

Description

@hcarvalhoalves
---------------------------------------------------------------------------
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

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions