code: def wrap_worker__run(*args, **kwargs):
      
      # Ignore parent's attempts to murder us when we still need to write
      # profiling output.
      if mitogen.core._profile_hook.__name__ != '_profile_hook':
          signal.signal(signal.SIGTERM, signal.SIG_IGN)
  
      ansible_mitogen.logging.set_process_name('task')
      ansible_mitogen.affinity.policy.assign_worker()
      return mitogen.core._profile_hook('WorkerProcess',
          lambda: worker__run(*args, **kwargs)
      )
docs: While the strategy is active, rewrite connection_loader.get() calls for
      some transports into requests for a compatible Mitogen transport.