We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8c0d771 commit 3464722Copy full SHA for 3464722
store/postgres/src/subgraph_store.rs
@@ -44,6 +44,7 @@ use crate::{
44
index::{IndexList, Method},
45
Layout,
46
},
47
+ retry,
48
writable::{SourceableStore, WritableStore},
49
NotificationSender,
50
};
@@ -290,8 +291,11 @@ impl SubgraphStore {
290
291
292
// Ideally the lower level functions would be asyncified.
293
let this = self.clone();
294
+ let logger2 = logger.cheap_clone();
295
let site = graph::spawn_blocking_allow_panic(move || -> Result<_, StoreError> {
- this.find_site(deployment)
296
+ retry::forever(&logger2, "get_or_create_writable_store", || {
297
+ this.find_site(deployment)
298
+ })
299
})
300
.await
301
.unwrap()?; // Propagate panics, there shouldn't be any.
0 commit comments