Fix bug.

infiniflow · Dec 28, 2023 · 1e3f635 · 1e3f635
1 parent bce73ba
commit 1e3f635
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/scheduler/fragment_task.cpp b/src/scheduler/fragment_task.cpp
@@ -120,7 +120,8 @@ bool FragmentTask::QuitFromWorkerLoop() {
         return false;
     }
     if (source_state_->state_type_ != SourceStateType::kQueue) {
-        Error<SchedulerException>("SourceStateType is not kQueue");
+        return false;
+        // Error<SchedulerException>("SourceStateType is not kQueue");
     }
     auto *queue_state = static_cast<QueueSourceState *>(source_state_.get());