From 13bf83f7dc82a08e239fdf2925fd68fb83fc7cd3 Mon Sep 17 00:00:00 2001 From: jradhakrishnan Date: Tue, 22 Aug 2023 17:08:37 +0530 Subject: [PATCH] Change field and method name --- src/main/java/ai/asserts/aws/TaskExecutorUtil.java | 12 ++++++------ .../asserts/aws/cloudwatch/alarms/AlarmFetcher.java | 2 +- .../aws/cloudwatch/query/MetricQueryProvider.java | 2 +- .../aws/exporter/ApiGatewayToLambdaBuilder.java | 2 +- .../ai/asserts/aws/exporter/DynamoDBExporter.java | 2 +- .../asserts/aws/exporter/EC2ToEBSVolumeExporter.java | 4 ++-- .../ai/asserts/aws/exporter/ECSTaskProvider.java | 2 +- .../java/ai/asserts/aws/exporter/EMRExporter.java | 2 +- .../aws/exporter/KinesisAnalyticsExporter.java | 2 +- .../aws/exporter/KinesisFirehoseExporter.java | 2 +- .../asserts/aws/exporter/KinesisStreamExporter.java | 2 +- .../asserts/aws/exporter/LBToASGRelationBuilder.java | 2 +- .../asserts/aws/exporter/LBToECSRoutingBuilder.java | 2 +- .../aws/exporter/LBToLambdaRoutingBuilder.java | 2 +- .../asserts/aws/exporter/LambdaCapacityExporter.java | 2 +- .../aws/exporter/LambdaEventSourceExporter.java | 2 +- .../aws/exporter/LambdaInvokeConfigExporter.java | 2 +- .../asserts/aws/exporter/LoadBalancerExporter.java | 2 +- .../ai/asserts/aws/exporter/MetricScrapeTask.java | 2 +- .../java/ai/asserts/aws/exporter/RDSExporter.java | 2 +- .../ai/asserts/aws/exporter/RedshiftExporter.java | 2 +- .../ai/asserts/aws/exporter/S3BucketExporter.java | 2 +- .../ai/asserts/aws/exporter/SNSTopicExporter.java | 2 +- .../ai/asserts/aws/exporter/SQSQueueExporter.java | 2 +- .../aws/exporter/TargetGroupLBMapProvider.java | 2 +- .../ai/asserts/aws/lambda/LambdaFunctionScraper.java | 2 +- 26 files changed, 32 insertions(+), 32 deletions(-) diff --git a/src/main/java/ai/asserts/aws/TaskExecutorUtil.java b/src/main/java/ai/asserts/aws/TaskExecutorUtil.java index b0accf3a..803213c0 100644 --- a/src/main/java/ai/asserts/aws/TaskExecutorUtil.java +++ b/src/main/java/ai/asserts/aws/TaskExecutorUtil.java @@ -22,7 +22,7 @@ public class TaskExecutorUtil { private final TaskThreadPool taskThreadPool; private final AWSApiCallRateLimiter rateLimiter; - private static final ThreadLocal tenantName = new ThreadLocal<>(); + private static final ThreadLocal accountDetails = new ThreadLocal<>(); public TaskExecutorUtil(@Qualifier("aws-api-calls-thread-pool") TaskThreadPool taskThreadPool, AWSApiCallRateLimiter rateLimiter) { @@ -30,16 +30,16 @@ public TaskExecutorUtil(@Qualifier("aws-api-calls-thread-pool") TaskThreadPool t this.rateLimiter = rateLimiter; } - public Future executeTenantTask(AWSAccount tenant, TenantTask task) { + public Future executeAccountTask(AWSAccount accountDetails, TenantTask task) { return taskThreadPool.getExecutorService().submit(() -> { - tenantName.set(tenant); + TaskExecutorUtil.accountDetails.set(accountDetails); try { return rateLimiter.call(task); } catch (Exception e) { - log.error("Failed to execute tenant task for tenant:" + tenant, e); + log.error("Failed to execute tenant task for tenant:" + accountDetails, e); return task.getReturnValueWhenError(); } finally { - tenantName.remove(); + TaskExecutorUtil.accountDetails.remove(); } }); } @@ -55,6 +55,6 @@ public void awaitAll(List> futures, Consumer consumer) { } public AWSAccount getAccountDetails() { - return tenantName.get(); + return accountDetails.get(); } } diff --git a/src/main/java/ai/asserts/aws/cloudwatch/alarms/AlarmFetcher.java b/src/main/java/ai/asserts/aws/cloudwatch/alarms/AlarmFetcher.java index dc3026a7..88312b8f 100644 --- a/src/main/java/ai/asserts/aws/cloudwatch/alarms/AlarmFetcher.java +++ b/src/main/java/ai/asserts/aws/cloudwatch/alarms/AlarmFetcher.java @@ -103,7 +103,7 @@ public void update() { continue; } accountRegion.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new CollectionBuilderTask() { @Override public List call() { diff --git a/src/main/java/ai/asserts/aws/cloudwatch/query/MetricQueryProvider.java b/src/main/java/ai/asserts/aws/cloudwatch/query/MetricQueryProvider.java index a4a436f0..1bd76915 100644 --- a/src/main/java/ai/asserts/aws/cloudwatch/query/MetricQueryProvider.java +++ b/src/main/java/ai/asserts/aws/cloudwatch/query/MetricQueryProvider.java @@ -102,7 +102,7 @@ Map>>> getQueriesInternal() { log.info("Will discover metrics and build metric queries for tenant {}, account {}", accountRegion.getTenant(), accountRegion.getAccountId()); accountRegion.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(accountRegion, new SimpleTenantTask() { + taskExecutorUtil.executeAccountTask(accountRegion, new SimpleTenantTask() { @Override public Void call() { buildQueries(scrapeConfig, region, accountRegion, account, queriesByAccount); diff --git a/src/main/java/ai/asserts/aws/exporter/ApiGatewayToLambdaBuilder.java b/src/main/java/ai/asserts/aws/exporter/ApiGatewayToLambdaBuilder.java index da08bcdc..aeec9375 100644 --- a/src/main/java/ai/asserts/aws/exporter/ApiGatewayToLambdaBuilder.java +++ b/src/main/java/ai/asserts/aws/exporter/ApiGatewayToLambdaBuilder.java @@ -96,7 +96,7 @@ public void update() { List>> futures = new ArrayList<>(); for (AWSAccount accountRegion : accountProvider.getAccounts()) { accountRegion.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new CollectionBuilderTask() { @Override public List call() { diff --git a/src/main/java/ai/asserts/aws/exporter/DynamoDBExporter.java b/src/main/java/ai/asserts/aws/exporter/DynamoDBExporter.java index b1eab7ae..f6139e8a 100644 --- a/src/main/java/ai/asserts/aws/exporter/DynamoDBExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/DynamoDBExporter.java @@ -83,7 +83,7 @@ public void update() { List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account, allSamples); diff --git a/src/main/java/ai/asserts/aws/exporter/EC2ToEBSVolumeExporter.java b/src/main/java/ai/asserts/aws/exporter/EC2ToEBSVolumeExporter.java index f69e9582..a6f0ea15 100644 --- a/src/main/java/ai/asserts/aws/exporter/EC2ToEBSVolumeExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/EC2ToEBSVolumeExporter.java @@ -103,14 +103,14 @@ public void update() { List>> futures = new ArrayList<>(); List>> volumeFutures = new ArrayList<>(); accountProvider.getAccounts().forEach(awsAccount -> awsAccount.getRegions().forEach(region -> { - futures.add(taskExecutorUtil.executeTenantTask(awsAccount, new CollectionBuilderTask() { + futures.add(taskExecutorUtil.executeAccountTask(awsAccount, new CollectionBuilderTask() { @Override public List call() { return buildEC2InstanceMetrics(region, awsAccount); } })); volumeFutures.add( - taskExecutorUtil.executeTenantTask(awsAccount, + taskExecutorUtil.executeAccountTask(awsAccount, new CollectionBuilderTask() { @Override public List call() { diff --git a/src/main/java/ai/asserts/aws/exporter/ECSTaskProvider.java b/src/main/java/ai/asserts/aws/exporter/ECSTaskProvider.java index 01e10ed3..323858d8 100644 --- a/src/main/java/ai/asserts/aws/exporter/ECSTaskProvider.java +++ b/src/main/java/ai/asserts/aws/exporter/ECSTaskProvider.java @@ -147,7 +147,7 @@ public void run() { for (AWSAccount account : accountProvider.getAccounts()) { ScrapeConfig scrapeConfig = scrapeConfigProvider.getScrapeConfig(account.getTenant()); for (String region : account.getRegions()) { - taskExecutorUtil.executeTenantTask(account, new SimpleTenantTask() { + taskExecutorUtil.executeAccountTask(account, new SimpleTenantTask() { @Override public Void call() { Map> clusterWiseNewTasks = new HashMap<>(); diff --git a/src/main/java/ai/asserts/aws/exporter/EMRExporter.java b/src/main/java/ai/asserts/aws/exporter/EMRExporter.java index 74d0d951..0dc4cae3 100644 --- a/src/main/java/ai/asserts/aws/exporter/EMRExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/EMRExporter.java @@ -71,7 +71,7 @@ public void update() { List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/KinesisAnalyticsExporter.java b/src/main/java/ai/asserts/aws/exporter/KinesisAnalyticsExporter.java index 675d0c44..cec82520 100644 --- a/src/main/java/ai/asserts/aws/exporter/KinesisAnalyticsExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/KinesisAnalyticsExporter.java @@ -77,7 +77,7 @@ public void update() { List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/KinesisFirehoseExporter.java b/src/main/java/ai/asserts/aws/exporter/KinesisFirehoseExporter.java index 73e0ce3d..39cd25a9 100644 --- a/src/main/java/ai/asserts/aws/exporter/KinesisFirehoseExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/KinesisFirehoseExporter.java @@ -90,7 +90,7 @@ public void update() { List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildMetricSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/KinesisStreamExporter.java b/src/main/java/ai/asserts/aws/exporter/KinesisStreamExporter.java index 34698bba..4ab863e7 100644 --- a/src/main/java/ai/asserts/aws/exporter/KinesisStreamExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/KinesisStreamExporter.java @@ -82,7 +82,7 @@ public void update() { List allSamples = new ArrayList<>(); List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + futures.add(taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/LBToASGRelationBuilder.java b/src/main/java/ai/asserts/aws/exporter/LBToASGRelationBuilder.java index b0fccd69..3ba5ed8c 100644 --- a/src/main/java/ai/asserts/aws/exporter/LBToASGRelationBuilder.java +++ b/src/main/java/ai/asserts/aws/exporter/LBToASGRelationBuilder.java @@ -97,7 +97,7 @@ public void updateRouting() { List>> futures = new ArrayList<>(); for (AWSAccount accountRegion : accountProvider.getAccounts()) { accountRegion.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new CollectionBuilderTask() { @Override public List call() { diff --git a/src/main/java/ai/asserts/aws/exporter/LBToECSRoutingBuilder.java b/src/main/java/ai/asserts/aws/exporter/LBToECSRoutingBuilder.java index 488c093f..df862be1 100644 --- a/src/main/java/ai/asserts/aws/exporter/LBToECSRoutingBuilder.java +++ b/src/main/java/ai/asserts/aws/exporter/LBToECSRoutingBuilder.java @@ -69,7 +69,7 @@ public void run() { Set newRouting = new HashSet<>(); List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(awsAccount -> awsAccount.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(awsAccount, + futures.add(taskExecutorUtil.executeAccountTask(awsAccount, new SimpleTenantTask>() { @Override public Set call() { diff --git a/src/main/java/ai/asserts/aws/exporter/LBToLambdaRoutingBuilder.java b/src/main/java/ai/asserts/aws/exporter/LBToLambdaRoutingBuilder.java index ba690152..3c3daf3c 100644 --- a/src/main/java/ai/asserts/aws/exporter/LBToLambdaRoutingBuilder.java +++ b/src/main/java/ai/asserts/aws/exporter/LBToLambdaRoutingBuilder.java @@ -55,7 +55,7 @@ public Set getRoutings() { List, Set>>> futures = new ArrayList<>(); for (AWSAccount accountRegion : accountProvider.getAccounts()) { accountRegion.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new SimpleTenantTask, Set>>() { @Override public Pair, Set> call() { diff --git a/src/main/java/ai/asserts/aws/exporter/LambdaCapacityExporter.java b/src/main/java/ai/asserts/aws/exporter/LambdaCapacityExporter.java index 8d0a3b59..b4fcec7b 100644 --- a/src/main/java/ai/asserts/aws/exporter/LambdaCapacityExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/LambdaCapacityExporter.java @@ -114,7 +114,7 @@ private List getMetrics() { String account = accountRegion.getAccountId(); Map> byRegion = byAccountByRegion.getOrDefault(account, Collections.emptyMap()); - byRegion.forEach((region, functions) -> futures.add(taskExecutorUtil.executeTenantTask( + byRegion.forEach((region, functions) -> futures.add(taskExecutorUtil.executeAccountTask( accountRegion, new SimpleTenantTask>>() { @Override public Map> call() { diff --git a/src/main/java/ai/asserts/aws/exporter/LambdaEventSourceExporter.java b/src/main/java/ai/asserts/aws/exporter/LambdaEventSourceExporter.java index 65e096d0..8a0a7384 100644 --- a/src/main/java/ai/asserts/aws/exporter/LambdaEventSourceExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/LambdaEventSourceExporter.java @@ -95,7 +95,7 @@ private List getMappings() { ScrapeConfig scrapeConfig = scrapeConfigProvider.getScrapeConfig(accountRegion.getTenant()); Optional lambdaConfig = scrapeConfig.getLambdaConfig(); lambdaConfig.ifPresent(namespaceConfig -> accountRegion.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new SimpleTenantTask>>() { @Override public Map> call() { diff --git a/src/main/java/ai/asserts/aws/exporter/LambdaInvokeConfigExporter.java b/src/main/java/ai/asserts/aws/exporter/LambdaInvokeConfigExporter.java index e8f119b0..a9dcc032 100644 --- a/src/main/java/ai/asserts/aws/exporter/LambdaInvokeConfigExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/LambdaInvokeConfigExporter.java @@ -108,7 +108,7 @@ List getInvokeConfigs() { Map> byRegion = new ConcurrentHashMap<>(byAccountByRegion.get(account)); byRegion.forEach((region, byARN) -> - futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new CollectionBuilderTask() { @Override public List call() { diff --git a/src/main/java/ai/asserts/aws/exporter/LoadBalancerExporter.java b/src/main/java/ai/asserts/aws/exporter/LoadBalancerExporter.java index 3fa63c2f..ad8c974d 100644 --- a/src/main/java/ai/asserts/aws/exporter/LoadBalancerExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/LoadBalancerExporter.java @@ -84,7 +84,7 @@ public void update() { List, List>>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(awsAccount -> awsAccount.getRegions().forEach(region -> { ScrapeConfig scrapeConfig = scrapeConfigProvider.getScrapeConfig(awsAccount.getTenant()); - futures.add(taskExecutorUtil.executeTenantTask(awsAccount, + futures.add(taskExecutorUtil.executeAccountTask(awsAccount, new SimpleTenantTask, List>>() { @Override public Pair, List> call() { diff --git a/src/main/java/ai/asserts/aws/exporter/MetricScrapeTask.java b/src/main/java/ai/asserts/aws/exporter/MetricScrapeTask.java index f3aff0c9..eb9ee698 100644 --- a/src/main/java/ai/asserts/aws/exporter/MetricScrapeTask.java +++ b/src/main/java/ai/asserts/aws/exporter/MetricScrapeTask.java @@ -101,7 +101,7 @@ public void update() { if (intervalSeconds <= 60 || System.currentTimeMillis() - lastRunTime > intervalSeconds * 1000L) { lastRunTime = System.currentTimeMillis(); try { - cache = taskExecutorUtil.executeTenantTask(account, + cache = taskExecutorUtil.executeAccountTask(account, new SimpleTenantTask>() { @Override public List call() { diff --git a/src/main/java/ai/asserts/aws/exporter/RDSExporter.java b/src/main/java/ai/asserts/aws/exporter/RDSExporter.java index c259a383..3b7a4da2 100644 --- a/src/main/java/ai/asserts/aws/exporter/RDSExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/RDSExporter.java @@ -88,7 +88,7 @@ public void update() { List allSamples = new ArrayList<>(); List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + futures.add(taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/RedshiftExporter.java b/src/main/java/ai/asserts/aws/exporter/RedshiftExporter.java index 58be8457..c936ac00 100644 --- a/src/main/java/ai/asserts/aws/exporter/RedshiftExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/RedshiftExporter.java @@ -79,7 +79,7 @@ public void update() { List allSamples = new ArrayList<>(); List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + futures.add(taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/S3BucketExporter.java b/src/main/java/ai/asserts/aws/exporter/S3BucketExporter.java index 423b0b21..b7519b4a 100644 --- a/src/main/java/ai/asserts/aws/exporter/S3BucketExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/S3BucketExporter.java @@ -84,7 +84,7 @@ public void update() { List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/SNSTopicExporter.java b/src/main/java/ai/asserts/aws/exporter/SNSTopicExporter.java index 93e3146a..68fc9629 100644 --- a/src/main/java/ai/asserts/aws/exporter/SNSTopicExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/SNSTopicExporter.java @@ -88,7 +88,7 @@ public void update() { List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/SQSQueueExporter.java b/src/main/java/ai/asserts/aws/exporter/SQSQueueExporter.java index ad6e0217..47336a2c 100644 --- a/src/main/java/ai/asserts/aws/exporter/SQSQueueExporter.java +++ b/src/main/java/ai/asserts/aws/exporter/SQSQueueExporter.java @@ -91,7 +91,7 @@ public void update() { List>> futures = new ArrayList<>(); accountProvider.getAccounts().forEach(account -> account.getRegions().forEach(region -> futures.add( - taskExecutorUtil.executeTenantTask(account, new CollectionBuilderTask() { + taskExecutorUtil.executeAccountTask(account, new CollectionBuilderTask() { @Override public List call() { return buildSamples(region, account); diff --git a/src/main/java/ai/asserts/aws/exporter/TargetGroupLBMapProvider.java b/src/main/java/ai/asserts/aws/exporter/TargetGroupLBMapProvider.java index f75f0bdc..4a5672a0 100644 --- a/src/main/java/ai/asserts/aws/exporter/TargetGroupLBMapProvider.java +++ b/src/main/java/ai/asserts/aws/exporter/TargetGroupLBMapProvider.java @@ -110,7 +110,7 @@ public void update() { List>> futures = new ArrayList<>(); for (AWSAccount accountRegion : accountProvider.getAccounts()) { accountRegion.getRegions() - .forEach(region -> futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + .forEach(region -> futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new CollectionBuilderTask() { @Override public List call() { diff --git a/src/main/java/ai/asserts/aws/lambda/LambdaFunctionScraper.java b/src/main/java/ai/asserts/aws/lambda/LambdaFunctionScraper.java index 23e2ec13..35c8ecec 100644 --- a/src/main/java/ai/asserts/aws/lambda/LambdaFunctionScraper.java +++ b/src/main/java/ai/asserts/aws/lambda/LambdaFunctionScraper.java @@ -147,7 +147,7 @@ private Map>> discoverFunctions( .filter(ns -> lambda.getNamespace().equals(ns.getName())) .findFirst(); lambdaNSOpt.ifPresent(lambdaNS -> accountRegion.getRegions().forEach(region -> - futures.add(taskExecutorUtil.executeTenantTask(accountRegion, + futures.add(taskExecutorUtil.executeAccountTask(accountRegion, new SimpleTenantTask>>>() { @Override public Map>> call() {