initial stage

2024-07-03 01:21:43 +02:00 · 2024-07-03 01:21:43 +02:00 · 8018975863
parent c7729c44e1
commit 8018975863
1 changed files with 1 additions and 1 deletions
--- 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)