|
|
@ -14,7 +14,7 @@ func ETLExtract() { |
|
|
} |
|
|
} |
|
|
log, _ := logger.NewLogger(-1, "Scheduler") |
|
|
log, _ := logger.NewLogger(-1, "Scheduler") |
|
|
taskService := svr.NewTaskHeadService() |
|
|
taskService := svr.NewTaskHeadService() |
|
|
taskLi, err := taskService.SelectWithDetail() |
|
|
|
|
|
|
|
|
taskLi, err := taskService.SelectWithDetail(model.STAGE_EXTRACT_DATA) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Error("ETLExtract get task failed, error:", err.Error()) |
|
|
log.Error("ETLExtract get task failed, error:", err.Error()) |
|
|
return |
|
|
return |
|
|
|
