docs: public List<Message> processForPipelines(Message message,
                                               Set<String> pipelineIds,
                                               InterpreterListener interpreterListener,
                                               State state) {
          final Map<String, Pipeline> currentPipelines = state.getCurrentPipelines();
          final ImmutableSet<Pipeline> pipelinesToRun = pipelineIds.stream()
                  .map(currentPipelines::get)
                  .filter(Objects::nonNull)
                  .collect(ImmutableSet.toImmutableSet());
  
          return processForResolvedPipelines(message, message.getId(), pipelinesToRun, interpreterListener, state);
      }