| 152 | Status StopProducingImpl() override { return Status::OK(); } |
| 153 | |
| 154 | Status InputReceived(ExecNode* input, ExecBatch batch) override { |
| 155 | auto scope = TraceInputReceived(batch); |
| 156 | DCHECK_EQ(input, inputs_[0]); |
| 157 | |
| 158 | return sequencing_queue_->InsertBatch(std::move(batch)); |
| 159 | } |
| 160 | |
| 161 | Result<std::optional<util::SequencingQueue::Task>> Process(ExecBatch batch) override { |
| 162 | if (finished_) { |