From 18bb17f04c80a2d02749dc685099ce294dbed482 Mon Sep 17 00:00:00 2001 From: Danglewood <85772166+deeleeramone@users.noreply.github.com> Date: Thu, 2 Jan 2025 00:42:27 -0800 Subject: [PATCH] blockingio error --- .../core/openbb_core/provider/utils/websockets/database.py | 5 ++++- .../extensions/websockets/openbb_websockets/helpers.py | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/openbb_platform/core/openbb_core/provider/utils/websockets/database.py b/openbb_platform/core/openbb_core/provider/utils/websockets/database.py index c307fd94694..168eed69c73 100644 --- a/openbb_platform/core/openbb_core/provider/utils/websockets/database.py +++ b/openbb_platform/core/openbb_core/provider/utils/websockets/database.py @@ -802,6 +802,9 @@ class DatabaseWriter: if start_time < earliest_timestamp: start_time = earliest_time + # Set end_time to be one interval after start_time + end_time = start_time + timedelta(minutes=minutes) + results_file = ( self.export_directory + "/" @@ -820,7 +823,7 @@ class DatabaseWriter: "read" ) as conn, conn.cursor() as cursor: await cursor.execute( - query, (start_time.isoformat(), cutoff_time.isoformat()) + query, (start_time.isoformat(), end_time.isoformat()) ) headers = OrderedDict() diff --git a/openbb_platform/extensions/websockets/openbb_websockets/helpers.py b/openbb_platform/extensions/websockets/openbb_websockets/helpers.py index 5a1ecd3f21b..92bba3e3850 100644 --- a/openbb_platform/extensions/websockets/openbb_websockets/helpers.py +++ b/openbb_platform/extensions/websockets/openbb_websockets/helpers.py @@ -69,7 +69,7 @@ class StdOutSink: import os import sys - os.set_blocking(sys.__stdout__.fileno(), False) # type: ignore + os.set_blocking(sys.__stdout__.fileno(), True) # type: ignore cleaned_message = AUTH_TOKEN_FILTER.sub(r"\1********", message) if cleaned_message != message: cleaned_message = f"{cleaned_message}\n"