diff --git a/dbms/src/Common/BackgroundSchedulePool.cpp b/dbms/src/Common/BackgroundSchedulePool.cpp index cc18871fa62..36d5a2bffce 100644 --- a/dbms/src/Common/BackgroundSchedulePool.cpp +++ b/dbms/src/Common/BackgroundSchedulePool.cpp @@ -131,8 +131,8 @@ void BackgroundSchedulePool::TaskInfo::execute() /// on the queue. We don't call the function again here because this way all tasks /// will have their chance to execute - if(scheduled && !deactivated) - pool.queue.enqueueNotification(new TaskNotification(shared_from_this())); + if(scheduled) + pool.queue.enqueueNotification(new TaskNotification(shared_from_this())); } }