| 72 | } |
| 73 | |
| 74 | std::shared_ptr<Task> makeTask( |
| 75 | const std::string& taskId, |
| 76 | const core::PlanNodePtr& planNode) { |
| 77 | auto queryCtx = core::QueryCtx::create(executor_.get()); |
| 78 | queryCtx->testingOverrideMemoryPool( |
| 79 | memory::memoryManager()->addRootPool(queryCtx->queryId())); |
| 80 | return Task::create( |
| 81 | taskId, |
| 82 | core::PlanFragment{planNode}, |
| 83 | 0, |
| 84 | std::move(queryCtx), |
| 85 | Task::ExecutionMode::kParallel, |
| 86 | exec::Consumer{}); |
| 87 | } |
| 88 | |
| 89 | int32_t enqueue( |
| 90 | const std::string& taskId, |
nothing calls this directly
no test coverage detected