frontend::get_current_epoch

oleiman · oleiman · commit edf08d6a913c · 2026-02-05T09:12:59.000-08:00
diff --git a/src/v/cloud_topics/frontend/frontend.cc b/src/v/cloud_topics/frontend/frontend.cc
@@ -1025,7 +1025,7 @@ ss::future<std::error_code> frontend::linearizable_barrier() {
 ss::future<std::expected<cloud_topics::cluster_epoch, frontend_errc>>
 frontend::get_current_epoch() noexcept {
     ss::abort_source as;
-    auto new_epoch = co_await _ctp_stm_api->get_current_epoch(&as);
+    auto new_epoch = co_await _data_plane->get_current_epoch(&as);
     if (!new_epoch.has_value()) {
         co_return std::unexpected{frontend_errc::timeout};
     }

Original file line number	Diff line number	Diff line change
`@@ -1025,7 +1025,7 @@ ss::future<std::error_code> frontend::linearizable_barrier() {`
`1025`	`1025`	`ss::future<std::expected<cloud_topics::cluster_epoch, frontend_errc>>`
`1026`	`1026`	`frontend::get_current_epoch() noexcept {`
`1027`	`1027`	`ss::abort_source as;`
`1028`		`- auto new_epoch = co_await _ctp_stm_api->get_current_epoch(&as);`
	`1028`	`+ auto new_epoch = co_await _data_plane->get_current_epoch(&as);`
`1029`	`1029`	`if (!new_epoch.has_value()) {`
`1030`	`1030`	`co_return std::unexpected{frontend_errc::timeout};`
`1031`	`1031`	`}`