diff --git a/synse_server/api/http.py b/synse_server/api/http.py index e057156f..1e9502ce 100644 --- a/synse_server/api/http.py +++ b/synse_server/api/http.py @@ -410,7 +410,10 @@ async def response_streamer(response): # just log it and move on. try: async for reading in cmd.read_cache(start, end): - await response.write(ujson.dumps(reading) + '\n') + try: + await response.write(ujson.dumps(reading, reject_bytes=False) + '\n') + except Exception: + logger.exception('error streaming cached reading response', reading=reading) except Exception: logger.exception('failure when streaming cached readings') diff --git a/synse_server/utils.py b/synse_server/utils.py index 7482dba3..991b398b 100644 --- a/synse_server/utils.py +++ b/synse_server/utils.py @@ -66,7 +66,7 @@ def _dumps(*arg, **kwargs) -> str: Returns: The given dictionary data dumped to a JSON string. """ - out = ujson.dumps(*arg, **kwargs) + out = ujson.dumps(*arg, reject_bytes=False, **kwargs) if not out.endswith('\n'): out += '\n' return out