diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 682bfbaf8d..da082b7f74 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -187,11 +187,9 @@ int32_t streamMetaRemoveTask(SStreamMeta* pMeta, int32_t taskId) {
     while (1) {
       int8_t schedStatus =
           atomic_val_compare_exchange_8(&pTask->schedStatus, TASK_SCHED_STATUS__INACTIVE, TASK_SCHED_STATUS__DROPPING);
-      if (schedStatus == TASK_SCHED_STATUS__INACTIVE) {
+      if (schedStatus != TASK_SCHED_STATUS__ACTIVE) {
         tFreeSStreamTask(pTask);
         break;
-      } else if (schedStatus == TASK_SCHED_STATUS__DROPPING) {
-        break;
       }
       taosMsleep(10);
     }