Skip to content

Commit d3ad11a

Browse files
committed
store: Do not use block_on in WritableStore.start_subgraph_deployment
1 parent d3c1399 commit d3ad11a

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

store/postgres/src/writable.rs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ use graph::{
2929
components::store::{self, write::EntityOp, WritableStore as WritableStoreTrait},
3030
data::subgraph::schema::SubgraphError,
3131
prelude::{
32-
BlockPtr, DeploymentHash, EntityModification, Error, Logger, StopwatchMetrics, StoreError,
32+
BlockPtr, DeploymentHash, EntityModification, Logger, StopwatchMetrics, StoreError,
3333
StoreEvent, UnfailOutcome, ENV_VARS,
3434
},
3535
slog::error,
@@ -1675,11 +1675,8 @@ impl WritableStoreTrait for WritableStore {
16751675
async fn start_subgraph_deployment(&self, logger: &Logger) -> Result<(), StoreError> {
16761676
let store = self.store.cheap_clone();
16771677
let logger = logger.cheap_clone();
1678-
graph::spawn_blocking_allow_panic(move || {
1679-
graph::block_on(store.start_subgraph_deployment(&logger))
1680-
})
1681-
.await
1682-
.map_err(Error::from)??;
1678+
1679+
store.start_subgraph_deployment(&logger).await?;
16831680

16841681
// Refresh all in memory state in case this instance was used before
16851682
*self.block_ptr.lock().unwrap() = self.store.block_ptr().await?;

0 commit comments

Comments
 (0)