diff options
| author | Alexey Bogolyubskiy <i@bogolyubskiyalexey.ru> | 2022-04-08 16:43:16 +0300 |
|---|---|---|
| committer | Alexey Bogolyubskiy <i@bogolyubskiyalexey.ru> | 2022-04-08 16:43:16 +0300 |
| commit | 15c9338e60c485641784de34fc2084469e98395c (patch) | |
| tree | 99cdded1e867c527999ca5eb415a932f5bb707b5 /ydb/core/ymq/actor/queue_leader.cpp | |
| parent | b30995f957aa40564245a566c3e1307c337a2844 (diff) | |
| download | ydb-15c9338e60c485641784de34fc2084469e98395c.tar.gz | |
[sqs] fix matching attrs and remove messages queries SQS-672
ref:55e30515e455f7e71be8a67664685ae446548ad9
Diffstat (limited to 'ydb/core/ymq/actor/queue_leader.cpp')
| -rw-r--r-- | ydb/core/ymq/actor/queue_leader.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/core/ymq/actor/queue_leader.cpp b/ydb/core/ymq/actor/queue_leader.cpp index c1a02b4bdf..250731b0df 100644 --- a/ydb/core/ymq/actor/queue_leader.cpp +++ b/ydb/core/ymq/actor/queue_leader.cpp @@ -2519,6 +2519,9 @@ void TQueueLeader::TDeleteBatch::Execute(TQueueLeader* leader) { .RetryOnTimeout() .OnExecuted([leader, shard = Shard, batchId = BatchId](const TSqsEvents::TEvExecuted::TRecord& ev) { leader->OnDeleteBatchExecuted(shard, batchId, ev); }) .Params() + .Uint64("QUEUE_ID_NUMBER", leader->QueueVersion_) + .Uint64("QUEUE_ID_NUMBER_HASH", GetKeysHash(leader->QueueVersion_)) + .Uint64("QUEUE_ID_NUMBER_AND_SHARD_HASH", GetKeysHash(leader->QueueVersion_, Shard)) .Uint64("NOW", TActivationContext::Now().MilliSeconds()) .AddWithType("SHARD", Shard, leader->TablesFormat_ == 1 ? NScheme::NTypeIds::Uint32 : NScheme::NTypeIds::Uint64) .Uint64("GROUPS_READ_ATTEMPT_IDS_PERIOD", Cfg().GetGroupsReadAttemptIdsPeriodMs()); |