fix: batch describe_services calls to handle >10 services

  AWS ECS describe_services API has a limit of 10 services per call.
  Updated get_service_info() to batch service names into groups of 10
  to avoid InvalidParameterException when clusters have more than 10 services.

Author: vertti

src/lazy_ecs/features/service/service.py

@@ -7,7 +7,7 @@
 
 from ...core.base import BaseAWSService
 from ...core.types import ServiceEvent, ServiceInfo
-from ...core.utils import determine_service_status, extract_name_from_arn, paginate_aws_list
+from ...core.utils import batch_items, determine_service_status, extract_name_from_arn, paginate_aws_list
 
 if TYPE_CHECKING:
     from typing import Any
@@ -31,9 +31,12 @@ def get_service_info(self, cluster_name: str) -> list[ServiceInfo]:
         if not service_names:
             return []
 
-        response = self.ecs_client.describe_services(cluster=cluster_name, services=service_names)
-        services = response.get("services", [])
-        return [_create_service_info(service) for service in services]
+        all_services = []
+        for batch in batch_items(service_names, 10):
+            response = self.ecs_client.describe_services(cluster=cluster_name, services=batch)
+            all_services.extend(response.get("services", []))
+
+        return [_create_service_info(service) for service in all_services]
 
     def get_desired_task_definition_arn(self, cluster_name: str, service_name: str) -> str | None:
         response = self.ecs_client.describe_services(cluster=cluster_name, services=[service_name])

tests/test_aws_service.py

@@ -268,6 +268,33 @@ def test_get_service_info(ecs_client_with_services) -> None:
         assert "pending_count" in info
 
 
+def test_get_service_info_with_more_than_10_services():
+    with mock_aws():
+        client = boto3.client("ecs", region_name="us-east-1")
+        client.create_cluster(clusterName="production")
+
+        client.register_task_definition(
+            family="app-task",
+            containerDefinitions=[{"name": "app", "image": "nginx", "memory": 256}],
+        )
+
+        for i in range(15):
+            client.create_service(
+                cluster="production",
+                serviceName=f"service-{i:02d}",
+                taskDefinition="app-task",
+                desiredCount=2,
+            )
+
+        service = ECSService(client)
+        service_info = service.get_service_info("production")
+
+        assert len(service_info) == 15
+        service_names = [info["name"] for info in service_info]
+        for i in range(15):
+            assert any(f"service-{i:02d}" in name for name in service_names)
+
+
 def test_get_tasks(ecs_client_with_tasks) -> None:
     service = ECSService(ecs_client_with_tasks)
     tasks = service.get_tasks("production", "web-api")