diff --git a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
index 332e6c83e3b4d31b0191b0f7b41aafd292046e79..0390cae0c0888f3902867e9db78e53e325c74a63 100644
--- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
+++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
@@ -177,11 +177,15 @@ public class FetchTaskThread implements Runnable{
                                 retryTimes--;
                             }
 
-                            if (taskInstance == null || !checkWorkerGroup(taskInstance, OSUtils.getHost())) {
+                            if (taskInstance == null ) {
                                 logger.error("task instance is null. task id : {} ", taskId);
                                 continue;
                             }
+                            if(!checkWorkerGroup(taskInstance, OSUtils.getHost())){
+                                continue;
+                            }
                             taskQueue.removeNode(Constants.SCHEDULER_TASKS_QUEUE, taskQueueStr);
+                            logger.info("remove task:{} from queue", taskQueueStr);
 
                             // set execute task worker host
                             taskInstance.setHost(OSUtils.getHost());