This is an automated email from the ASF dual-hosted git repository.
potiuk 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 221249e872 Fixed logging issue (#30703)
221249e872 is described below
commit 221249e8726d4082634912a27840011771f713be
Author: Mark Richman <[email protected]>
AuthorDate: Tue Apr 18 14:08:42 2023 -0400
Fixed logging issue (#30703)
Co-authored-by: Mark Richman <[email protected]>
---
airflow/providers/amazon/aws/sensors/dynamodb.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/airflow/providers/amazon/aws/sensors/dynamodb.py
b/airflow/providers/amazon/aws/sensors/dynamodb.py
index 6e229bbbab..bcc8f5f546 100644
--- a/airflow/providers/amazon/aws/sensors/dynamodb.py
+++ b/airflow/providers/amazon/aws/sensors/dynamodb.py
@@ -84,7 +84,9 @@ class DynamoDBValueSensor(BaseSensorOperator):
try:
self.log.info("Response: %s", response)
self.log.info("Want: %s = %s", self.attribute_name,
self.attribute_value)
- self.log.info("Got: {response['Item'][self.attribute_name]} = %s",
self.attribute_value)
+ self.log.info(
+ "Got: {response['Item'][self.attribute_name]} = %s",
response["Item"][self.attribute_name]
+ )
return response["Item"][self.attribute_name] ==
self.attribute_value
except KeyError:
return False