Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
Gabriel39 committed Dec 19, 2024
1 parent 42532ad commit 6e2fe8b
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions be/src/pipeline/task_queue.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -210,8 +210,7 @@ Status MultiCoreTaskQueue::push_back(std::shared_ptr<PipelineTask>& task, int co
<< " task: " << task->debug_string();
auto eager = core_id == _eager_queue_idx;
if (!task->put_in_runnable_queue(eager)) {
DCHECK(task->query_context()->is_cancelled() && !eager)
<< " eager: " << eager << " task: " << task->debug_string();
DCHECK(task->query_context()->is_cancelled()) << " task: " << task->debug_string();
return Status::OK();
}
return _prio_task_queues[core_id].push(task);
Expand Down

0 comments on commit 6e2fe8b

Please sign in to comment.