Method StartTask

driver/driver.go:571–615

(cfg *drivers.TaskConfig)

}

func (d *Driver) StartTask(cfg *drivers.TaskConfig) (*drivers.TaskHandle, *drivers.DriverNetwork, error) {
	d.logger.Info("StartTask", "ID", cfg.ID, "allocID", cfg.AllocID, "jobName", cfg.JobName, "taskName", cfg.Name)

	err := common.ValidateJobName(cfg.JobName)
	if err != nil {
		return nil, nil, err
	}

	if _, ok := d.tasks.Get(cfg.ID); ok {
		return nil, nil, fmt.Errorf("task with ID %q already started", cfg.ID)
	}
	d.logger.Debug("start dtle task 1")
	var dtleTaskConfig common.DtleTaskConfig

	if err := cfg.DecodeDriverConfig(&dtleTaskConfig); err != nil {
		d.logger.Debug("start dtle task err")
		return nil, nil, errors.Wrap(err, "DecodeDriverConfig")
	}

	if err := d.verifyDriverConfig(dtleTaskConfig); nil != err {
		return nil, nil, fmt.Errorf("invalide driver config, errors: %v", err)
	}
	dtleTaskConfig.SetDefaultForEmpty()

	handle := drivers.NewTaskHandle(taskHandleVersion)
	handle.Config = cfg
	driverState := TaskState{
		TaskConfig:     cfg,
		DtleTaskConfig: &dtleTaskConfig,
		StartedAt:      time.Now().Round(time.Millisecond),
	}
	if err := handle.SetDriverState(&driverState); err != nil {
		d.logger.Error("failed to start task, error setting driver state", "error", err)
		return nil, nil, errors.Wrap(err, "SetDriverState")
	}

	h := newDtleTaskHandle(d.ctx, d.logger, cfg, drivers.TaskStateRunning, time.Now().Round(time.Millisecond))
	h.driverConfig = &common.MySQLDriverConfig{DtleTaskConfig: dtleTaskConfig}
	d.tasks.Set(cfg.ID, h)
	AllocIdTaskNameToTaskHandler.Set(cfg.AllocID, cfg.Name, cfg.ID, h)

	go h.run(d)

	return handle, nil, nil
}

func (d *Driver) verifyDriverConfig(config common.DtleTaskConfig) error {
	errMsgs := []string{}