Function executeTask

src/QueryPipeline/DistributedPlanExecutor.cpp:757–770

}

static void executeTask(const UUID & unique_query_id, const DistributedQueryTaskDescription & task, ContextPtr context, std::shared_ptr<std::atomic<bool>> is_cancelled)
{
    auto [object_storage, object_storage_path] = getObjectStorageForTemporaryFiles(toString(unique_query_id), context);

    /// Run each task as an independent query fragment with its own query context and thread group,
    /// matching the worker path. Attaching the task context to this thread (instead of sharing the
    /// initiator's) gives the task its own per-query state, such as the runtime filter lookup.
    auto task_context = Context::createCopy(context);
    task_context->makeQueryContext();
    auto query_scope = QueryScope::create(task_context);
    setThreadName(ThreadName::DISTRIBUTED_QUERY_TASK);

    doExecuteTask(task, object_storage, object_storage_path, toString(unique_query_id), std::move(task_context), [is_cancelled]() -> bool { return *is_cancelled; });
}

/// Runs tasks in local threads. Useful for testing and debugging.
class DistributedQueryPlanExecutorLocal final : public DistributedQueryPlanExecutor