updated variable name

apache · Sep 22, 2024 · 111c632 · 111c632
1 parent 49e83ab
commit 111c632
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/airflow/providers/google/cloud/sensors/pubsub.py b/airflow/providers/google/cloud/sensors/pubsub.py
@@ -183,8 +183,8 @@ def execute_complete(self, context: Context, event: dict[str, str | list[str]])
         if event["status"] == "success":
             self.log.info("Sensor pulls messages: %s", event["message"])
             if self.messages_callback:
-                message = self._convert_to_received_message(event["message"])
-                message_callback_response = self.messages_callback(message, context)
+                received_message_fmt = self._convert_to_received_message(event["message"])
+                message_callback_response = self.messages_callback(received_message_fmt, context)
 
                 return message_callback_response