code: def _patched_pool_worker(original_worker, *args, **kwargs):
      if not PatchOsFork._current_task:
          return original_worker(*args, **kwargs)
  
      try:
          if len(args) >= 2 and hasattr(args[1], "put"):
              args = list(args)
              args[1] = SimpleQueueWrapper(
                  PatchOsFork._current_task, args[1]
              )
              args = tuple(args)
          elif "outqueue" in kwargs and hasattr(
              kwargs["outqueue"], "put"
          ):
              kwargs["outqueue"] = SimpleQueueWrapper(
                  PatchOsFork._current_task, kwargs["outqueue"]
              )
      except:  # noqa
          pass
  
      return original_worker(*args, **kwargs)
  
imports: import os
  from functools import partial
  from time import sleep
  from multiprocessing import pool
  import six
  from ..config import TASK_LOG_ENVIRONMENT, running_remotely, config
  from ..utilities.process.mp import BackgroundMonitor
label_desc: Use image node_id 2 for calling the PatchOsFork obj's underlying member method code with example usage: obj._patched_pool_worker(original_worker) and returns: original_worker, original_worker