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)