This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 f2b7bb8803 Partial fix for example_dynamodb_to_s3.py (#41517)
f2b7bb8803 is described below
commit f2b7bb880345aeaaebdbb5ef48a6ef3bb87d821e
Author: D. Ferruzzi <ferru...@amazon.com>
AuthorDate: Fri Aug 16 04:17:33 2024 -0700
Partial fix for example_dynamodb_to_s3.py (#41517)
`backup_db_to_point_in_time_incremental_export` still fails with
"Incremental export period from time should not be greater or equal to
incremental export period to time"
---
airflow/providers/amazon/aws/transfers/dynamodb_to_s3.py | 2 +-
tests/system/providers/amazon/aws/example_dynamodb_to_s3.py | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/airflow/providers/amazon/aws/transfers/dynamodb_to_s3.py
b/airflow/providers/amazon/aws/transfers/dynamodb_to_s3.py
index c40001bbff..f7670cfd83 100644
--- a/airflow/providers/amazon/aws/transfers/dynamodb_to_s3.py
+++ b/airflow/providers/amazon/aws/transfers/dynamodb_to_s3.py
@@ -148,7 +148,7 @@ class DynamoDBToS3Operator(AwsToAwsBaseOperator):
self.point_in_time_export = point_in_time_export
self.export_time = export_time
self.export_format = export_format
- self.export_table_to_point_in_time_kwargs =
export_table_to_point_in_time_kwargs
+ self.export_table_to_point_in_time_kwargs =
export_table_to_point_in_time_kwargs or {}
self.check_interval = check_interval
self.max_attempts = max_attempts
diff --git a/tests/system/providers/amazon/aws/example_dynamodb_to_s3.py
b/tests/system/providers/amazon/aws/example_dynamodb_to_s3.py
index c39abd3b80..225aaa7803 100644
--- a/tests/system/providers/amazon/aws/example_dynamodb_to_s3.py
+++ b/tests/system/providers/amazon/aws/example_dynamodb_to_s3.py
@@ -225,6 +225,7 @@ with DAG(
backup_db_segment_1,
backup_db_segment_2,
export_time,
+ latest_export_time,
backup_db_to_point_in_time_full_export,
backup_db_to_point_in_time_incremental_export,
# TEST TEARDOWN
