Skip to content

Commit 7b4f0d1

Browse files
committed
Fix mkql query
1 parent 6f3f8ea commit 7b4f0d1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/core/ymq/queues/common/queries.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -96,11 +96,11 @@ extern const char* const MatchQueueAttributesQuery = R"__(
9696
(And
9797
(And
9898
(And (Equal (Member queuesRead 'Shards) shards)
99-
(Equal (Member queuesRead 'Tags) tags))
99+
(Equal (Coalesce (Member queuesRead 'Tags) (Utf8String '"{}")) tags))
100100
(Equal (Member queuesRead 'Partitions) partitions))
101101
(Equal (Member queuesRead 'FifoQueue) fifo))
102102
(Equal (Coalesce (Member queuesRead 'DlqName) (Utf8String '"")) dlqName))
103-
(Bool 'true)))
103+
(Bool 'false)))
104104
105105
(let attrRow '(
106106
)__" ATTRS_KEYS_PARAM R"__(
@@ -122,7 +122,7 @@ extern const char* const MatchQueueAttributesQuery = R"__(
122122
(Equal (Member attrRead 'MessageRetentionPeriod) retention)))
123123
(Equal (Member attrRead 'VisibilityTimeout) visibility))
124124
(Equal (Coalesce (Member attrRead 'MaxReceiveCount) (Uint64 '0)) maxReceiveCount))
125-
(Bool 'true)))
125+
(Bool 'false)))
126126
127127
(let sameVersion
128128
(Equal currentVersion expectedVersion))

0 commit comments

Comments
 (0)