Update c2_pub_sub.py

IQTLabs · Apr 22, 2024 · 3cff9f7 · 3cff9f7
1 parent 7fab2b7
commit 3cff9f7
Showing 1 changed file with 22 additions and 22 deletions.
diff --git a/skyscan-c2/c2_pub_sub.py b/skyscan-c2/c2_pub_sub.py
@@ -531,30 +531,30 @@ def _target_selection_callback(
                             f"Failed to send data: {out_json} on topic: {self.object_topic}"
                         )
 
-                    out_json = self.generate_payload_json(
-                        push_timestamp=str(int(datetime.utcnow().timestamp())),
-                        device_type="Collector",
-                        id_=self.hostname,
-                        deployment_id=f"ShipScan-{self.hostname}",
-                        current_location="-90, -180",
-                        status="Debug",
-                        message_type="Event",
-                        model_version="null",
-                        firmware_version="v0.0.0",
-                        data_payload_type="Prioritized Object Ledger",
-                        data_payload=json.dumps(object_ledger_df.to_json()),
-                    )
+                out_json = self.generate_payload_json(
+                    push_timestamp=str(int(datetime.utcnow().timestamp())),
+                    device_type="Collector",
+                    id_=self.hostname,
+                    deployment_id=f"ShipScan-{self.hostname}",
+                    current_location="-90, -180",
+                    status="Debug",
+                    message_type="Event",
+                    model_version="null",
+                    firmware_version="v0.0.0",
+                    data_payload_type="Prioritized Object Ledger",
+                    data_payload=json.dumps(object_ledger_df.to_json()),
+                )
 
-                    success = self.publish_to_topic(
-                        self.prioritized_ledger_topic, out_json
+                success = self.publish_to_topic(
+                    self.prioritized_ledger_topic, out_json
+                )
+                if success:
+                    logging.debug(
+                        f"Successfully sent data: {out_json} on topic: {self.object_topic}"
                     )
-                    if success:
-                        logging.debug(
-                            f"Successfully sent data: {out_json} on topic: {self.object_topic}"
-                        )
-                    else:
-                        logging.warning(
-                            f"Failed to send data: {out_json} on topic: {self.object_topic}"
+                else:
+                    logging.warning(
+                        f"Failed to send data: {out_json} on topic: {self.object_topic}"
                         )
         if "ObjectIDOverride" in payload_dict.keys():
             self.override_object = str(payload_dict["ObjectIDOverride"])