Get exception added by worker

def extract_worker_exc(*arg, **kw):
    """Get exception added by worker"""
    _self = arg[0]
    if not isinstance(_self, StrategyBase):
        # Run for StrategyBase instance only
        return
    # Iterate over workers to get their task and queue
    for _worker_prc, _main_q, _rslt_q in _self._workers:
        _task = _worker_prc._task
        if _task.action == 'setup':
            # Ignore setup
            continue
        # Do till queue is empty for the worker
        while True:
            try:
                _exc = _rslt_q.get(block=False, interceptor=True)
                RESULT[_task.name].add(_exc)
            except Empty:
                break