diff --git a/airflow/dags/skg_if_pipeline.py b/airflow/dags/skg_if_pipeline.py
index 3ad3939..19ac0c0 100644
--- a/airflow/dags/skg_if_pipeline.py
+++ b/airflow/dags/skg_if_pipeline.py
@@ -33,7 +33,7 @@ def unzip_to_s3(key: str, bucket: str):
 
     with TemporaryDirectory() as tmp_dir:
         archive = f'{tmp_dir}/{key}'
-        hook.download_file(key, bucket_name=bucket, local_path=archive)
+        hook.download_file(key, bucket_name=bucket, local_path=archive, preserve_file_name=True, use_autogenerated_subdir=False)
         with zipfile.ZipFile(archive, 'r') as zip_ref:
             zip_ref.extractall(tmp_dir)