Method create

bolt/exec/Task.cpp:248–269

static.

// static.
std::shared_ptr<Task> Task::create(
    const std::string& taskId,
    core::PlanFragment planFragment,
    int destination,
    std::shared_ptr<core::QueryCtx> queryCtx,
    ExecutionMode mode,
    Consumer consumer,
    int32_t memoryArbitrationPriority,
    std::optional<common::SpillDiskOptions> spillDiskOpts,
    std::function<void(std::exception_ptr)> onError) {
  return Task::create(
      taskId,
      std::move(planFragment),
      destination,
      std::move(queryCtx),
      mode,
      (consumer ? [c = std::move(consumer)]() { return c; }
                : ConsumerSupplier{}),
      memoryArbitrationPriority,
      std::move(spillDiskOpts),
      std::move(onError));
}

std::shared_ptr<Task> Task::create(
    const std::string& taskId,