docs: def worker(f):
      """Generic wrapper to log uncaught exceptions in a function.
  
      When we cross concurrent.futures executor boundaries we lose our
      traceback information, and when doing bulk operations we may tolerate
      transient failures on a partial subset. However we still want to have
      full accounting of the error in the logs, in a format that our error
      collection (cwl subscription) can still pickup.
      """
      def _f(*args, **kw):
          try:
              return f(*args, **kw)
          except Exception:
              worker_log.exception(
                  'Error invoking %s',
                  "%s.%s" % (f.__module__, f.__name__))
              raise
      functools.update_wrapper(_f, f)
      return _f