You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2023/04/18 18:08:52 UTC

[airflow] branch main updated: Fixed logging issue (#30703)

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 <mr...@users.noreply.github.com>
AuthorDate: Tue Apr 18 14:08:42 2023 -0400

    Fixed logging issue (#30703)
    
    Co-authored-by: Mark Richman <mr...@amazon.com>
---
 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