1#include "duckdb/parallel/pipeline_event.hpp"
2#include "duckdb/execution/executor.hpp"
3
4namespace duckdb {
5
6PipelineEvent::PipelineEvent(shared_ptr<Pipeline> pipeline_p) : BasePipelineEvent(std::move(pipeline_p)) {
7}
8
9void PipelineEvent::Schedule() {
10 auto event = shared_from_this();
11 auto &executor = pipeline->executor;
12 try {
13 pipeline->Schedule(event);
14 D_ASSERT(total_tasks > 0);
15 } catch (Exception &ex) {
16 executor.PushError(exception: PreservedError(ex));
17 } catch (std::exception &ex) {
18 executor.PushError(exception: PreservedError(ex));
19 } catch (...) { // LCOV_EXCL_START
20 executor.PushError(exception: PreservedError("Unknown exception in Finalize!"));
21 } // LCOV_EXCL_STOP
22}
23
24void PipelineEvent::FinishEvent() {
25}
26
27} // namespace duckdb
28