blockingio error

This commit is contained in:
Danglewood
2025-01-02 00:42:27 -08:00
parent 516a68cf7f
commit 18bb17f04c
2 changed files with 5 additions and 2 deletions

View File

@@ -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()

View File

@@ -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"