diff --git a/scheduler/extract.go b/scheduler/extract.go
index 277b0d8..760f63c 100644
--- a/scheduler/extract.go
+++ b/scheduler/extract.go
@@ -14,7 +14,7 @@ func ETLExtract() {
 	}
 	log, _ := logger.NewLogger(-1, "Scheduler")
 	taskService := svr.NewTaskHeadService()
-	taskLi, err := taskService.SelectWithDetail()
+	taskLi, err := taskService.SelectWithDetail(model.STAGE_EXTRACT_DATA)
 	if err != nil {
 		log.Error("ETLExtract get task failed, error:", err.Error())
 		return