add debug test

ymakedaq · Nov 25, 2024 · d3e38d6 · d3e38d6
1 parent 2c2857b
commit d3e38d6
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/dbm-services/mysql/db-simulation/app/service/simulation_task.go b/dbm-services/mysql/db-simulation/app/service/simulation_task.go
@@ -351,7 +351,7 @@ func (t *SimulationTask) SimulationRun(containerName string, xlogger *logger.Log
 	err error) {
 	logger.Info("will execute in %s", containerName)
 	doneChan := make(chan struct{})
-	ticker := time.NewTicker(30 * time.Second)
+	ticker := time.NewTicker(1 * time.Second)
 	go func() {
 		for {
 			select {

diff --git a/dbm-services/mysql/db-simulation/model/tb_simulation_task.go b/dbm-services/mysql/db-simulation/model/tb_simulation_task.go
@@ -110,11 +110,12 @@ func CreateTask(taskid, requestid, version string, billTaskId string) (err error
 		return err
 	}
 	return DB.Create(&TbSimulationTask{
-		TaskId:       taskid,
-		RequestID:    requestid,
-		BillTaskId:   billTaskId,
-		MySQLVersion: version,
-		Phase:        PhaseWaitting,
-		CreateTime:   time.Now(),
+		TaskId:        taskid,
+		RequestID:     requestid,
+		BillTaskId:    billTaskId,
+		MySQLVersion:  version,
+		Phase:         PhaseWaitting,
+		HeartbeatTime: time.Now(),
+		CreateTime:    time.Now(),
 	}).Error
 }