We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 35962c6 commit ceb9681Copy full SHA for ceb9681
rust/cubestore/cubestore/src/cachestore/cache_rocksstore.rs
@@ -1083,7 +1083,6 @@ impl CacheStore for RocksCacheStore {
1083
),
1084
batch_pipe,
1085
)?;
1086
-
1087
if added {
1088
let queue_payload_schema = QueueItemPayloadRocksTable::new(db_ref.clone());
1089
queue_payload_schema.insert_with_pk(
@@ -1097,7 +1096,7 @@ impl CacheStore for RocksCacheStore {
1097
1096
1098
}
1099
1100
- (queue_item_row.id, true)
+ (queue_item_row.id, added)
1101
};
1102
1103
Ok(QueueAddResponse {
0 commit comments