code: def extract_worker_exc(*arg, **kw):
      
      _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
docs: Get exception added by worker