@@ -445,7 +445,8 @@ export class Agent {
445
445
async ( ) => {
446
446
if ( PERFORMANCE_CONFIG . PARALLEL_NETWORK_QUERIES ) {
447
447
// Fetch all network deployments in parallel
448
- const networkDeployments = await this . multiNetworks . map ( async ( { network } : NetworkAndOperator ) => {
448
+ const networkDeployments = await this . multiNetworks . map (
449
+ async ( { network } : NetworkAndOperator ) => {
449
450
const networkId = network . specification . networkIdentifier
450
451
const loader = this . dataLoader . get ( networkId )
451
452
@@ -463,7 +464,8 @@ export class Agent {
463
464
deployments :
464
465
await network . networkMonitor . subgraphDeployments ( ) ,
465
466
}
466
- } )
467
+ } ,
468
+ )
467
469
468
470
const deploymentMap : NetworkMapped < SubgraphDeployment [ ] > = { }
469
471
for ( const result of Object . values ( networkDeployments ) ) {
@@ -941,16 +943,17 @@ export class Agent {
941
943
return join ( { networkDeployments, indexingRules } ) . tryMap (
942
944
async ( { networkDeployments, indexingRules } ) => {
943
945
const decisionsEntries = await Promise . all (
944
- Object . entries ( this . multiNetworks . zip ( indexingRules , networkDeployments ) ) . map (
945
- async ( [ networkId , [ rules , deployments ] ] ) => {
946
- const decisions = rules . length === 0
946
+ Object . entries (
947
+ this . multiNetworks . zip ( indexingRules , networkDeployments ) ,
948
+ ) . map ( async ( [ networkId , [ rules , deployments ] ] ) => {
949
+ const decisions =
950
+ rules . length === 0
947
951
? [ ]
948
952
: await evaluateDeployments ( this . logger , deployments , rules )
949
- return [ networkId , decisions ]
950
- }
951
- )
953
+ return [ networkId , decisions ]
954
+ } ) ,
952
955
)
953
-
956
+
954
957
const decisions = Object . fromEntries ( decisionsEntries )
955
958
956
959
return uniqueDeployments ( [
@@ -975,16 +978,17 @@ export class Agent {
975
978
return join ( { networkDeployments, indexingRules } ) . tryMap (
976
979
async ( { networkDeployments, indexingRules } ) => {
977
980
const decisionsEntries = await Promise . all (
978
- Object . entries ( this . multiNetworks . zip ( indexingRules , networkDeployments ) ) . map (
979
- async ( [ networkId , [ rules , deployments ] ] ) => {
980
- const decisions = rules . length === 0
981
+ Object . entries (
982
+ this . multiNetworks . zip ( indexingRules , networkDeployments ) ,
983
+ ) . map ( async ( [ networkId , [ rules , deployments ] ] ) => {
984
+ const decisions =
985
+ rules . length === 0
981
986
? [ ]
982
987
: await evaluateDeployments ( this . logger , deployments , rules )
983
- return [ networkId , decisions ]
984
- }
985
- )
988
+ return [ networkId , decisions ]
989
+ } ) ,
986
990
)
987
-
991
+
988
992
return Object . fromEntries ( decisionsEntries )
989
993
} ,
990
994
{
0 commit comments