1#include "duckdb/parallel/pipeline_finish_event.hpp"
2#include "duckdb/execution/executor.hpp"
3
4namespace duckdb {
5
6PipelineFinishEvent::PipelineFinishEvent(shared_ptr<Pipeline> pipeline_p) : BasePipelineEvent(std::move(pipeline_p)) {
7}
8
9void PipelineFinishEvent::Schedule() {
10}
11
12void PipelineFinishEvent::FinishEvent() {
13 pipeline->Finalize(event&: *this);
14}
15
16} // namespace duckdb
17