code: function createInitiateBatchTask(batch, context) {
      // Define a new initiate batch task definition for the batch & update the batch with it
      batch.taskDefs.initiateTaskDef = defineInitiateBatchTask();
  
      // Create a new initiate batch task (and all of its sub-tasks) from the task definition
      const task = context.taskFactory.createTask(batch.taskDefs.initiateTaskDef, initiateTaskOpts);
  
      // Cache it on the batch
      const initiatingTasks = batch.getOrSetInitiatingTasks();
      initiatingTasks[task.name] = task;
  
      return task;
    }
docs: Creates a new initiate batch task to be used to initiate the batch and to track the state of the initiating
  (pre-processing) phase.
  @param {Batch} batch - the batch to be initiated
  @param {StreamConsumerContext} context - the context to use
  @returns {InitiateBatchTask} a new initiate batch task (with sub-tasks)