Remove returns in final clause of S3ToDynamoDBOperator (apache#43456)

* Remove returns in final clause of S3ToDynamoDBOperator * remove temp table in finally * remove duplicate log Co-authored-by: rom sharon <[email protected]> * remove except statement * remove test case --------- Co-authored-by: rom sharon <[email protected]>
romsharon98 · Nov 5, 2024 · d8f71a2 · d8f71a2
1 parent b9b0614
commit d8f71a2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/providers/src/airflow/providers/amazon/aws/transfers/s3_to_dynamodb.py b/providers/src/airflow/providers/amazon/aws/transfers/s3_to_dynamodb.py
@@ -240,7 +240,7 @@ def _load_into_existing_table(self) -> str:
         finally:
             self.log.info("Delete tmp DynamoDB table %s", self.tmp_table_name)
             client.delete_table(TableName=self.tmp_table_name)
-            return dynamodb_hook.get_conn().Table(self.dynamodb_table_name).table_arn
+        return dynamodb_hook.get_conn().Table(self.dynamodb_table_name).table_arn
 
     def execute(self, context: Context) -> str:
         """