File tree Expand file tree Collapse file tree 1 file changed +13
-9
lines changed
lib/executor/src/executors Expand file tree Collapse file tree 1 file changed +13
-9
lines changed Original file line number Diff line number Diff line change @@ -300,15 +300,19 @@ impl SubgraphExecutorMap {
300300 if let Some ( subgraph_traffic_shaping_config) =
301301 self . config . traffic_shaping . subgraphs . get ( subgraph_name)
302302 {
303- client = Arc :: new (
304- Client :: builder ( TokioExecutor :: new ( ) )
305- . pool_timer ( TokioTimer :: new ( ) )
306- . pool_idle_timeout ( Duration :: from_secs (
307- subgraph_traffic_shaping_config. pool_idle_timeout_seconds ,
308- ) )
309- . pool_max_idle_per_host ( self . max_connections_per_host )
310- . build ( HttpsConnector :: new ( ) ) ,
311- ) ;
303+ if subgraph_traffic_shaping_config. pool_idle_timeout_seconds
304+ != self . config . traffic_shaping . all . pool_idle_timeout_seconds
305+ {
306+ client = Arc :: new (
307+ Client :: builder ( TokioExecutor :: new ( ) )
308+ . pool_timer ( TokioTimer :: new ( ) )
309+ . pool_idle_timeout ( Duration :: from_secs (
310+ subgraph_traffic_shaping_config. pool_idle_timeout_seconds ,
311+ ) )
312+ . pool_max_idle_per_host ( self . max_connections_per_host )
313+ . build ( HttpsConnector :: new ( ) ) ,
314+ ) ;
315+ }
312316 dedupe_enabled = subgraph_traffic_shaping_config. dedupe_enabled ;
313317 timeout = subgraph_traffic_shaping_config. request_timeout . clone ( ) ;
314318 }
You can’t perform that action at this time.
0 commit comments