Adding hash to pipelines processing step function execution names to …

…prevent collisions
awslabs · Jul 24, 2023 · af85438 · af85438
1 parent 8989a29
commit af85438
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ry/adf-bootstrap/deployment/lambda_codebase/pipeline_management/process_deployment_map.py b/...ry/adf-bootstrap/deployment/lambda_codebase/pipeline_management/process_deployment_map.py
@@ -177,8 +177,8 @@ def start_executions(
         # truncated version concatenated with an hash generated from
         # the pipeline name
         truncated_pipeline_name = full_pipeline_name[:24]
-        truncated_pipeline_name_hash = hashlib.md5( bytes(full_pipeline_name, 'utf-8') ).hexdigest()[:5]
-        sfn_execution_name = f"{truncated_pipeline_name}-{truncated_pipeline_name_hash}-{run_id}"
+        execution_unique_hash = hashlib.md5( bytes(full_pipeline_name + run_id, 'utf-8') ).hexdigest()[:5]
+        sfn_execution_name = f"{truncated_pipeline_name}-{execution_unique_hash}-{run_id}"
         sfn_client.start_execution(
             stateMachineArn=PIPELINE_MANAGEMENT_STATEMACHINE,
             name=sfn_execution_name,