Skip to content

Commit abf766f

Browse files
committed
Fix carnot dcompilation issue
Signed-off-by: Dom Del Nano <ddelnano@gmail.com>
1 parent 2db4c86 commit abf766f

1 file changed

Lines changed: 9 additions & 0 deletions

File tree

src/carnot/engine_state.h

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,9 @@ class EngineState : public NotCopyable {
8787
[this](const std::string& remote_addr, bool insecure) {
8888
return TraceStubGenerator(remote_addr, insecure);
8989
},
90+
[this](const std::string& remote_addr, bool insecure) {
91+
return LogsStubGenerator(remote_addr, insecure);
92+
},
9093
query_id, model_pool_.get(), grpc_router_, add_auth_to_grpc_context_func_, metrics_.get());
9194
}
9295
std::shared_ptr<grpc::Channel> CreateChannel(const std::string& remote_addr, bool insecure) {
@@ -115,6 +118,12 @@ class EngineState : public NotCopyable {
115118
CreateChannel(remote_addr, insecure));
116119
}
117120

121+
std::unique_ptr<opentelemetry::proto::collector::logs::v1::LogsService::StubInterface>
122+
LogsStubGenerator(const std::string& remote_addr, bool insecure) {
123+
return opentelemetry::proto::collector::logs::v1::LogsService::NewStub(
124+
CreateChannel(remote_addr, insecure));
125+
}
126+
118127
std::unique_ptr<plan::PlanState> CreatePlanState() {
119128
return std::make_unique<plan::PlanState>(func_registry_.get());
120129
}

0 commit comments

Comments
 (0)