From 4eb832506e2e05514cd2c95e7cd26007a27b9407 Mon Sep 17 00:00:00 2001 From: Mark Richman Date: Tue, 18 Apr 2023 10:59:00 +0000 Subject: [PATCH] Fixed logging issue --- 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 6e229bbbab2b7..bcc8f5f54615a 100644 --- a/airflow/providers/amazon/aws/sensors/dynamodb.py +++ b/airflow/providers/amazon/aws/sensors/dynamodb.py @@ -84,7 +84,9 @@ def poke(self, context: Context) -> bool: 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