diff --git a/ses-lambda-new-python/lambda_function.py b/ses-lambda-new-python/lambda_function.py
index be51094..7170406 100644
--- a/ses-lambda-new-python/lambda_function.py
+++ b/ses-lambda-new-python/lambda_function.py
@@ -335,7 +335,7 @@ def _process_email(event, context):
         if recipients:
             domain = recipients[0].split('@', 1)[1]
             bucket = domain_to_bucket(domain)
-            prefix = f"emails/{msg_id}"
+            prefix = f"{msg_id}"
             print(f"SES event: domain={domain}, bucket={bucket}, prefix={prefix}")
             resp_list = s3.list_objects_v2(Bucket=bucket, Prefix=prefix)
             if 'Contents' not in resp_list or not resp_list['Contents']: