code: func (e *engineImpl) kickLaunchInvocationsBatchTask(c context.Context, jobID string, invIDs []int64) error {
  	payload := &internal.LaunchInvocationsBatchTask{
  		Tasks: make([]*internal.LaunchInvocationTask, 0, len(invIDs)),
  	}
  	for _, invID := range invIDs {
  		payload.Tasks = append(payload.Tasks, &internal.LaunchInvocationTask{
  			JobId: jobID,
  			InvId: invID,
  		})
  	}
  	return e.cfg.Dispatcher.AddTask(c, &tq.Task{
  		Payload: payload,
  		Delay:   time.Second, // give some time to land Invocation transactions
  	})
  }
docs: ////////////////////////////////////////////////////////////////////////////////
  // Task queue handlers.
  // kickLaunchInvocationsBatchTask enqueues LaunchInvocationsBatchTask that
  // eventually launches new invocations.