From f3a6a405b65e3aa2b1328bc96f6b31dab937f078 Mon Sep 17 00:00:00 2001 From: Abhishek Pandey Date: Wed, 6 Jul 2022 20:06:34 +0530 Subject: [PATCH] issue-5757: s3-prefix-fix-added (#5876) * issue-5757: s3-prefix-fix-added * updated-f-string-in-prefix --- ingestion/src/metadata/ingestion/source/database/datalake.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ingestion/src/metadata/ingestion/source/database/datalake.py b/ingestion/src/metadata/ingestion/source/database/datalake.py index 82f6caef64e..2fd23b36acb 100644 --- a/ingestion/src/metadata/ingestion/source/database/datalake.py +++ b/ingestion/src/metadata/ingestion/source/database/datalake.py @@ -170,7 +170,7 @@ class DatalakeSource(Source[Entity]): def get_s3_files(self, bucket_name, prefix): kwargs = {"Bucket": bucket_name} if prefix: - kwargs["prefix"] = prefix + kwargs["Prefix"] = prefix if prefix.endswith("/") else f"{prefix}/" for key in self.client.list_objects(**kwargs)["Contents"]: try: if filter_by_table(