1#include "duckdb/parallel/pipeline_complete_event.hpp"
2#include "duckdb/execution/executor.hpp"
3
4namespace duckdb {
5
6PipelineCompleteEvent::PipelineCompleteEvent(Executor &executor, bool complete_pipeline_p)
7 : Event(executor), complete_pipeline(complete_pipeline_p) {
8}
9
10void PipelineCompleteEvent::Schedule() {
11}
12
13void PipelineCompleteEvent::FinalizeFinish() {
14 if (complete_pipeline) {
15 executor.CompletePipeline();
16 }
17}
18
19} // namespace duckdb
20