This is an automated email from the ASF dual-hosted git repository.
rom pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new d8f71a2d9f Remove returns in final clause of S3ToDynamoDBOperator
(#43456)
d8f71a2d9f is described below
commit d8f71a2d9fbc281ed1de281a00ddee6fbebaf0f7
Author: yangyulely <[email protected]>
AuthorDate: Tue Nov 5 17:38:05 2024 +0800
Remove returns in final clause of S3ToDynamoDBOperator (#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]>
---
providers/src/airflow/providers/amazon/aws/transfers/s3_to_dynamodb.py | 2 +-
1 file changed, 1 insertion(+), 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
index 5522f90628..57b18299a8 100644
--- 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 @@ class S3ToDynamoDBOperator(BaseOperator):
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:
"""
