code: func (e *engineImpl) execFanOutTriggersTask(c context.Context, tqTask proto.Message) error {
  	msg := tqTask.(*internal.FanOutTriggersTask)
  
  	tasks := make([]*tq.Task, len(msg.JobIds))
  	for i, jobID := range msg.JobIds {
  		tasks[i] = &tq.Task{
  			Payload: &internal.EnqueueTriggersTask{
  				JobId:    jobID,
  				Triggers: msg.Triggers,
  			},
  		}
  	}
  
  	return e.cfg.Dispatcher.AddTask(c, tasks...)
  }
docs: ////////////////////////////////////////////////////////////////////////////////
  // Triggers handling.
  // execFanOutTriggersTask handles a batch enqueue of triggers.
  //
  // It is enqueued transactionally by the invocation, and results in a bunch of
  // non-transactional EnqueueTriggersTask tasks.