Method start

bolt/exec/tests/utils/Cursor.cpp:306–321

Starts the task if not started yet.

  /// Starts the task if not started yet.
  void start() override {
    if (!started_) {
      started_ = true;
      try {
        task_->start(maxDrivers_, numConcurrentSplitGroups_);
        queue_->setNumProducers(numSplitGroups_ * task_->numOutputDrivers());
      } catch (const BoltException& e) {
        // Could not find output pipeline, due to Task terminated before
        // start. Do not override the error.
        if (e.message().find("Output pipeline not found for task") ==
            std::string::npos) {
          throw;
        }
      }
    }
  }

  /// Fetches another batch from the task queue.
  /// Starts the task if not started yet.