Skip to content

Commit

Permalink
fix ut
Browse files Browse the repository at this point in the history
Signed-off-by: silverbullet233 <[email protected]>
  • Loading branch information
silverbullet233 committed Feb 5, 2025
1 parent f9193e5 commit 490048e
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion be/test/exec/pipeline/schedule/observer_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -187,12 +187,13 @@ struct SimpleTestContext {
auto operators = pipeline.create_operators(1, 0);
driver = std::make_unique<PipelineDriver>(operators, query_ctx, fragment_ctx, &pipeline, 1);
driver->assign_observer();
driver_queue = std::make_unique<QuerySharedDriverQueue>();
driver_queue = std::make_unique<QuerySharedDriverQueue>(metrics.get_driver_queue_metrics());
fragment_ctx->init_event_scheduler();
fragment_ctx->event_scheduler()->attach_queue(driver_queue.get());
}

Pipeline pipeline;
PipelineExecutorMetrics metrics;
std::unique_ptr<DriverQueue> driver_queue;
std::unique_ptr<PipelineDriver> driver;
};
Expand Down

0 comments on commit 490048e

Please sign in to comment.