YT-19178: Support replicated objects (rt/chaos) in queue agent (trim, statuses, metrics)

1 files changed, 2 insertions, 0 deletions

diff --git a/yt/yt/client/queue_client/consumer_client.cpp b/yt/yt/client/queue_client/consumer_client.cpp
index 6380be70956..a0557dbdc6b 100644
--- a/yt/yt/client/queue_client/consumer_client.cpp
+++ b/yt/yt/client/queue_client/consumer_client.cpp
@@ -349,6 +349,7 @@ private:
         YT_LOG_DEBUG("Collecting partitions (Query: %v)", selectQuery);
 
         TSelectRowsOptions selectRowsOptions;
+        selectRowsOptions.ReplicaConsistency = EReplicaConsistency::Sync;
         auto selectRowsResult = WaitFor(client->SelectRows(selectQuery, selectRowsOptions))
             .ValueOrThrow();
 
@@ -422,6 +423,7 @@ private:
         options.KeepMissingRows = true;
         options.RetentionConfig = New<TRetentionConfig>();
         options.RetentionConfig->MaxDataVersions = 1;
+        options.ReplicaConsistency = EReplicaConsistency::Sync;
 
         auto versionedRowset = WaitFor(client->VersionedLookupRows(
             Path_,