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 265580f commit 91d57deCopy full SHA for 91d57de
rust/cubestore/cubestore/src/sql/cache.rs
@@ -267,13 +267,15 @@ impl SqlResultCache {
267
) -> Result<Arc<DataFrame>, CubeError> {
268
if let Some(receiver) = &mut receiver {
269
loop {
270
+ // Currently we should never loop -- we only send sender a `Some(_)` value.
271
receiver.changed().await?;
- let x = receiver.borrow();
272
+ let x = receiver.borrow_and_update();
273
let value = x.as_ref();
274
if let Some(value) = value {
275
trace!("Using cache for '{}'", query);
276
return value.clone();
277
}
278
+ log::warn!("Queue query cache is (impossibly) looping for '{}'", query);
279
280
281
panic!("Unexpected state: wait receiver expected but cache was empty")
0 commit comments