From 8018975863cc2892020c07d80e1f47511a8ea767 Mon Sep 17 00:00:00 2001 From: Giambattista Bloisi Date: Wed, 3 Jul 2024 01:21:43 +0200 Subject: [PATCH] initial stage --- airflow/dags/S3_untar.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/dags/S3_untar.py b/airflow/dags/S3_untar.py index 8d19cff..294a971 100644 --- a/airflow/dags/S3_untar.py +++ b/airflow/dags/S3_untar.py @@ -43,7 +43,7 @@ def load_file_obj_with_backoff(hook: S3Hook, fileobj, key:str, bucket:str, repla while delay < max_delay: try: - hook.load_file_obj(fileobj, + return hook.load_file_obj(fileobj, key, bucket, replace=replace)