Release: 1.9.1

Author: AWS

VERSION

@@ -1 +1 @@
-1.9.0
+1.9.1

sources/aft-lambda-layer/aft_common/codepipeline.py

@@ -102,30 +102,31 @@ def list_pipelines(session: Session) -> List[Any]:
     return matched_pipelines
 
 
-def get_running_pipeline_count(session: Session, names: List[str]) -> int:
+def get_running_pipeline_count(session: Session, pipeline_names: List[str]) -> int:
     pipeline_counter = 0
     client = session.client("codepipeline")
 
-    for p in names:
-        logger.info("Getting pipeline executions for " + p)
-
-        response = client.list_pipeline_executions(pipelineName=p)
-        pipeline_execution_summaries = response["pipelineExecutionSummaries"]
-
-        while "nextToken" in response:
-            response = client.list_pipeline_executions(
-                pipelineName=p, nextToken=response["nextToken"]
-            )
-            pipeline_execution_summaries.extend(response["pipelineExecutionSummaries"])
-
-        latest_execution = sorted(
-            pipeline_execution_summaries, key=lambda i: i["startTime"], reverse=True  # type: ignore
-        )[0]
-        logger.info("Latest Execution: ")
-        logger.info(latest_execution)
-
-        if latest_execution["status"] == "InProgress":
-            pipeline_counter += 1
+    for name in pipeline_names:
+        logger.info("Getting pipeline executions for " + name)
+        pipeline_execution_summaries = []
+
+        paginator = client.get_paginator("list_pipeline_executions")
+        pages = paginator.paginate(pipelineName=name)
+        for page in pages:
+            pipeline_execution_summaries.extend(page["pipelineExecutionSummaries"])
+
+        if not pipeline_execution_summaries:
+            # No executions for this pipeline in the last 12 months
+            continue
+        else:
+            latest_execution = sorted(
+                pipeline_execution_summaries, key=lambda i: i["startTime"], reverse=True  # type: ignore
+            )[0]
+            logger.info("Latest Execution: ")
+            logger.info(latest_execution)
+
+            if latest_execution["status"] == "InProgress":
+                pipeline_counter += 1
 
     logger.info("The number of running pipelines is " + str(pipeline_counter))
 

src/aft_lambda/aft_account_request_framework/aft_account_request_action_trigger.py

@@ -52,6 +52,16 @@ def lambda_handler(event: Dict[str, Any], context: LambdaContext) -> None:
             logger.info("New account request received")
             record_handler.handle_account_request(new_account=True)
 
+        # In this situation, a new entry has been added to the account request table
+        # and a provisioned product exists, and No Control Tower parameters changed
+        elif (
+            record_handler.is_create_action
+            and provisioned_product_exists(record=record_handler.record)
+            and not record_handler.control_tower_parameters_updated
+        ):
+            logger.info("Customization request received for existing CT account")
+            record_handler.handle_customization_request()
+
         # If we're processing a request that updates an existing entry in the
         # account request table, we need to handle control tower parameter changes
         # by routing the request to service catalog