Method runTask

src/common/task_system/task_scheduler.cpp:215–223

}

void TaskScheduler::runTask(Task* task) {
    try {
        task->run();
        task->deRegisterThreadAndFinalizeTask();
    } catch (std::exception& e) {
        task->setException(std::current_exception());
        task->deRegisterThreadAndFinalizeTask();
    }
}

TaskScheduler* TaskScheduler::Get(const main::ClientContext& context) {
    return context.getDatabase()->getQueryProcessor()->getTaskScheduler();