diff --git a/repair/repair.cc b/repair/repair.cc
index 2cf5bbc63e..c32bf4a6e7 100644
--- a/repair/repair.cc
+++ b/repair/repair.cc
@@ -1309,7 +1309,7 @@ future<> data_sync_repair_task_impl::run() {
 
     auto id = get_repair_uniq_id();
     rlogger.info("repair[{}]: sync data for keyspace={}, status=started", id.uuid(), keyspace);
-    co_await module->run(id, [this, &rs, id, &db, keyspace, germs = std::move(germs), &ranges = _ranges, &neighbors = _neighbors, reason = _reason, ops_info = _ops_info] () mutable {
+    co_await module->run(id, [this, &rs, id, &db, keyspace, germs = std::move(germs), &ranges = _ranges, &neighbors = _neighbors, reason = _reason] () mutable {
         auto cfs = list_column_families(db, keyspace);
         if (cfs.empty()) {
             rlogger.warn("repair[{}]: sync data for keyspace={}, no table in this keyspace", id.uuid(), keyspace);
diff --git a/repair/repair_task.hh b/repair/repair_task.hh
index 654acbfbd7..a6f2f58986 100644
--- a/repair/repair_task.hh
+++ b/repair/repair_task.hh
@@ -63,17 +63,15 @@ class data_sync_repair_task_impl : public repair_task_impl {
 private:
     dht::token_range_vector _ranges;
     std::unordered_map<dht::token_range, repair_neighbors> _neighbors;
-    shared_ptr<node_ops_info> _ops_info;
     optimized_optional<abort_source::subscription> _abort_subscription;
 public:
     data_sync_repair_task_impl(tasks::task_manager::module_ptr module, repair_uniq_id id, std::string keyspace, std::string entity, dht::token_range_vector ranges, std::unordered_map<dht::token_range, repair_neighbors> neighbors, streaming::stream_reason reason, shared_ptr<node_ops_info> ops_info)
         : repair_task_impl(module, id.uuid(), id.id, std::move(keyspace), "", std::move(entity), tasks::task_id::create_null_id(), reason)
         , _ranges(std::move(ranges))
         , _neighbors(std::move(neighbors))
-        , _ops_info(ops_info) 
     {
-        if (_ops_info && _ops_info->as) {
-            _abort_subscription = _ops_info->as->subscribe([this] () noexcept {
+        if (ops_info && ops_info->as) {
+            _abort_subscription = ops_info->as->subscribe([this] () noexcept {
                 (void)abort();
             });
         }