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 58fdf36 commit e127f20Copy full SHA for e127f20
lib/executor/src/executors/map.rs
@@ -1,6 +1,7 @@
1
use std::{
2
collections::{BTreeMap, HashMap},
3
- sync::Arc, time::Duration,
+ sync::Arc,
4
+ time::Duration,
5
};
6
7
use bytes::{BufMut, Bytes, BytesMut};
@@ -344,7 +345,10 @@ impl SubgraphExecutorMap {
344
345
if let Some(subgraph_traffic_shaping_config) =
346
self.config.traffic_shaping.subgraphs.get(subgraph_name)
347
{
- if subgraph_traffic_shaping_config.pool_idle_timeout_seconds.is_some() {
348
+ if subgraph_traffic_shaping_config
349
+ .pool_idle_timeout_seconds
350
+ .is_some()
351
+ {
352
client = Arc::new(
353
Client::builder(TokioExecutor::new())
354
.pool_timer(TokioTimer::new())
0 commit comments