diff --git a/backend/moonstream/routes/streams.py b/backend/moonstream/routes/streams.py index 6aec9630..a14ad4c0 100644 --- a/backend/moonstream/routes/streams.py +++ b/backend/moonstream/routes/streams.py @@ -133,8 +133,7 @@ async def stream_handler( raise_on_error=True, ) except ReceivingEventsException as e: - logger.error(e) - logger.error("Error receiving events from provider") + logger.error(f"Error receiving events from provider err: {e}") raise MoonstreamHTTPException(status_code=500, internal_error=e) except Exception as e: logger.error("Unable to get events") @@ -177,8 +176,7 @@ async def latest_events_handler( sort_events=True, ) except ReceivingEventsException as e: - logger.error(e) - logger.error("Error receiving events from provider") + logger.error(f"Error receiving events from provider err: {e}") raise MoonstreamHTTPException(status_code=500, internal_error=e) except Exception as e: logger.error("Unable to get latest events") @@ -206,7 +204,6 @@ async def next_event_handler( All times must be given as seconds since the Unix epoch. """ - print("next") stream_boundary = data.StreamBoundary( start_time=start_time, end_time=end_time, @@ -234,8 +231,7 @@ async def next_event_handler( raise_on_error=True, ) except ReceivingEventsException as e: - print(e) - logger.error("Error receiving events from provider") + logger.error(f"Error receiving events from provider err: {e}") raise MoonstreamHTTPException(status_code=500, internal_error=e) except Exception as e: logger.error(e) @@ -264,7 +260,6 @@ async def previous_event_handler( All times must be given as seconds since the Unix epoch. """ - print("previous") stream_boundary = data.StreamBoundary( start_time=start_time, end_time=end_time, @@ -292,8 +287,7 @@ async def previous_event_handler( raise_on_error=True, ) except ReceivingEventsException as e: - print(e) - logger.error("Error receiving events from provider") + logger.error(f"Error receiving events from provider err: {e}") raise MoonstreamHTTPException(status_code=500, internal_error=e) except Exception as e: logger.error(e)