docs: @Override
      protected void sendMessage(@NonNull INDArray message, int iterationNumber, int epochNumber) {
          // here we'll send our stuff to other executores over the wire
          // and let's pray for udp broadcast availability
  
          // Send this message away
          // FIXME: do something with unsafe duplication, which is bad and used ONLY for local spark
          try (MemoryWorkspace wsO = Nd4j.getMemoryManager().scopeOutOfWorkspaces()) {
              long updateId = updatesCounter.getAndIncrement();
  
              val m = message.unsafeDuplication();
              ModelParameterServer.getInstance().sendUpdate(m, iterationNumber, epochNumber);
          }
  
  
          // heere we update local queue
          super.sendMessage(message, iterationNumber, epochNumber);
      }