Skip to content

Commit

Permalink
Fix json dump error (#202)
Browse files Browse the repository at this point in the history
* Fix json dump error

* Fix formatting
  • Loading branch information
Teddy-1000 authored Oct 9, 2024
1 parent 0845662 commit 4bc06bb
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions ingest/api/ingest.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,6 @@ def __init__(
mqtt_conf: dict,
uuid_prefix: str,
):

self.uuid_prefix = uuid_prefix
self.client = None
if mqtt_conf["host"]:
Expand All @@ -53,7 +52,6 @@ def seconds_to_iso_8601_duration(self, seconds: int) -> str:
return iso_duration

def convert_to_meter(self, level: int) -> str:

level = str(float(level) / 100)
return level

Expand All @@ -80,7 +78,6 @@ async def publish_messages(self, messages: list):
raise HTTPException(status_code=500, detail="API could not reach datastore")

if self.client is not None:

for msg in messages:
topic = (
msg["properties"]["naming_authority"]
Expand All @@ -96,10 +93,11 @@ async def publish_messages(self, messages: list):
msg["properties"]["level"] = level_string
msg["properties"]["period"] = period_iso
try:
send_message(topic, json.dump(msg), self.client)
logger.info("Succesfully published to mqtt")
send_message(topic, json.dumps(msg), self.client)
logger.debug("Succesfully published to mqtt")
except Exception as e:
logger.error("Failed to publish to mqtt, " + "\n" + str(e))
logger.error("Failed to publish to mqtt, " + str(e))
raise HTTPException(
status_code=500, detail="Data ingested to datastore. But unable to publish to mqtt"
status_code=500,
detail="Data ingested to datastore. But unable to publish to mqtt",
)

1 comment on commit 4bc06bb

@github-actions
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

API Unit Test Coverage Report
FileStmtsMissCoverMissing
\_\_init\_\_.py00100% 
datastore_pb2.py614821%34–81
datastore_pb2_grpc.py542750%15–16, 19, 65–80, 121–123, 128–130, 135–137, 142–144, 148–173, 219, 246, 273, 300
export_metrics.py100100% 
grpc_getter.py201145%15–19, 23–26, 30–32, 36–38
locustfile.py15150%1–31
main.py43784%45, 50, 60, 70–71, 81–82
metadata_endpoints.py653152%45–54, 58, 85, 100–219, 223
response_classes.py50100% 
utilities.py1744674%20, 38, 45, 67–70, 78–89, 94–101, 121, 125, 127, 155, 161, 179, 193–194, 198, 214–218, 222–228, 232–234, 264, 268, 290, 295
custom_geo_json
   edr_feature_collection.py60100% 
formatters
   \_\_init\_\_.py110100% 
   covjson.py59198%91
   geojson.py21290%27, 52
openapi
   custom_dimension_examples.py40100% 
   edr_query_parameter_descriptions.py110100% 
   openapi_examples.py130100% 
routers
   \_\_init\_\_.py00100% 
   edr.py101496%348–349, 438–439
   feature.py471960%99–132, 148–153, 159–181
TOTAL72021171% 

API Unit Test Coverage Summary

Tests Skipped Failures Errors Time
30 0 💤 0 ❌ 0 🔥 1.969s ⏱️

Please sign in to comment.