diff --git a/sstables_loader.cc b/sstables_loader.cc index 7252d07c0a..eff23538f3 100644 --- a/sstables_loader.cc +++ b/sstables_loader.cc @@ -650,26 +650,25 @@ public: virtual future get_progress() const override { co_return co_await with_shared(_progress_mutex, [this] -> future { - // TODO: fix the indent - switch (_progress_state) { - case progress_state::uninitialized: - co_return tasks::task_manager::task::progress{}; - case progress_state::finalized: - co_return _final_progress; - case progress_state::initialized: - break; - } - auto p = co_await _progress_per_shard.map_reduce( - adder{}, - [] (const progress_holder& holder) -> stream_progress { - auto p = holder.progress; - SCYLLA_ASSERT(p); - return *p; - }); - co_return tasks::task_manager::task::progress { - .completed = p.completed, - .total = p.total, - }; + switch (_progress_state) { + case progress_state::uninitialized: + co_return tasks::task_manager::task::progress{}; + case progress_state::finalized: + co_return _final_progress; + case progress_state::initialized: + break; + } + auto p = co_await _progress_per_shard.map_reduce( + adder{}, + [] (const progress_holder& holder) -> stream_progress { + auto p = holder.progress; + SCYLLA_ASSERT(p); + return *p; + }); + co_return tasks::task_manager::task::progress { + .completed = p.completed, + .total = p.total, + }; }); } };