docs: private void notifyPipelinedConsumers() {
  		if (sendScheduleOrUpdateConsumersMessage && !hasNotifiedPipelinedConsumers && partitionType.isPipelined()) {
  			partitionConsumableNotifier.notifyPartitionConsumable(jobId, partitionId, taskActions);
  
  			hasNotifiedPipelinedConsumers = true;
  		}
  	}