code: def _sendReply(self, destination, fid, *args):
          
          # Try to send the result directly to its parent
          self.addPeer(destination)
  
          try:
              self.direct_socket.send_multipart([
                  destination,
                  REPLY,
              ] + list(args),
                  flags=zmq.NOBLOCK)
          except zmq.error.ZMQError as e:
              # Fallback on Broker routing if no direct connection possible
              scoop.logger.debug(
                  "{0}: Could not send result directly to peer {1}, routing through "
                  "broker.".format(scoop.worker, destination)
              )
              self.socket.send_multipart([
                  REPLY, 
                  ] + list(args) + [
                  destination,
              ])
  
          self.socket.send_multipart([
              STATUS_DONE,
              fid,
          ])
docs: Send a REPLY directly to its destination. If it doesn't work, launch
          it back to the broker.