Skip to content

Commit 00ae774

Browse files
committed
change bucket name to dps destination
1 parent 0935502 commit 00ae774

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

lambdas/filenameprocessor/src/file_name_processor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ def handle_extended_attributes_file(
244244
"""
245245
try:
246246
extended_attribute_identifier = validate_extended_attributes_file_key(file_key)
247-
move_file_outside_bucket(bucket_name, file_key, DPS_DESTINATION_BUCKET_NAME, f"archive/{file_key}")
247+
move_file_outside_bucket(bucket_name, file_key, DPS_DESTINATION_BUCKET_NAME, f"dps_destination/{file_key}")
248248
queue_name = extended_attribute_identifier
249249

250250
upsert_audit_table(

lambdas/filenameprocessor/tests/test_lambda_handler.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ def test_lambda_handler_extended_attributes_success(self):
292292
self.assertEqual(item[AuditTableKeys.TIMESTAMP]["S"], test_cases[0].created_at_formatted_string)
293293
self.assertEqual(item[AuditTableKeys.EXPIRES_AT]["N"], str(test_cases[0].expires_at))
294294
# File should be moved to destination under archive/
295-
dest_key = f"archive/{test_cases[0].file_key}"
295+
dest_key = f"dps_destination/{test_cases[0].file_key}"
296296
print(f" destination file is at {s3_client.list_objects(Bucket=BucketNames.DESTINATION)}")
297297
retrieved = s3_client.get_object(Bucket=BucketNames.DESTINATION, Key=dest_key)
298298
self.assertIsNotNone(retrieved)

0 commit comments

Comments
 (0)