code: @Override
      public void pickTraining(@NonNull SkipGramRequestMessage message) {
          RequestDescriptor descriptor =
                          RequestDescriptor.createDescriptor(message.getOriginatorId(), message.getTaskId());
          if (!chains.containsKey(descriptor)) {
              SkipGramChain chain = new SkipGramChain(message);
              //            log.info("sI_{} Picking chain: originator: {}; taskId: {}", transport.getShardIndex(), message.getOriginatorId(), message.getTaskId());
              chains.put(descriptor, chain);
          }
      }
docs: This method will be called from non-initialized Shard context
  @param message