From 48b2218800830823593f19bc46fdb564915660b7 Mon Sep 17 00:00:00 2001 From: Darius <7328225+dariussantaras@users.noreply.github.com> Date: Fri, 22 Sep 2023 18:42:57 +0100 Subject: [PATCH] Ecs provider fix (#2056) * Include cluster name in describe tasks call * Fix poll interval to be based on seconds --- src/Proto.Cluster.AmazonECS/AmazonEcsProvider.cs | 2 +- src/Proto.Cluster.AmazonECS/EcsUtils.cs | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/Proto.Cluster.AmazonECS/AmazonEcsProvider.cs b/src/Proto.Cluster.AmazonECS/AmazonEcsProvider.cs index 62372f5c56..85aa042f6c 100644 --- a/src/Proto.Cluster.AmazonECS/AmazonEcsProvider.cs +++ b/src/Proto.Cluster.AmazonECS/AmazonEcsProvider.cs @@ -140,7 +140,7 @@ private void StartClusterMonitor() => Logger.LogError(x, "Failed to get members from ECS"); } - await Task.Delay(_config.PollIntervalSeconds).ConfigureAwait(false); + await Task.Delay(TimeSpan.FromSeconds(_config.PollIntervalSeconds)).ConfigureAwait(false); } } ); diff --git a/src/Proto.Cluster.AmazonECS/EcsUtils.cs b/src/Proto.Cluster.AmazonECS/EcsUtils.cs index 6644c654a5..b2575918b6 100644 --- a/src/Proto.Cluster.AmazonECS/EcsUtils.cs +++ b/src/Proto.Cluster.AmazonECS/EcsUtils.cs @@ -37,6 +37,7 @@ public static async Task GetMembers(this AmazonECSClient c, string ecs var describedTasks = await c.DescribeTasksAsync(new DescribeTasksRequest { Include = { "TAGS" }, + Cluster = ecsClusterName, Tasks = instanceArns } ).ConfigureAwait(false);