From a7d25cbf8e5ce442acae0de43973cfde1c9ef3ef Mon Sep 17 00:00:00 2001 From: afonso pinto Date: Thu, 9 Jan 2025 22:02:25 +0000 Subject: [PATCH] CELE-119 style: Apply linting --- .../visualizer/backend/api/decorators/streaming.py | 7 +++++-- ingestion/ingestion/ingest.py | 2 +- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/applications/visualizer/backend/api/decorators/streaming.py b/applications/visualizer/backend/api/decorators/streaming.py index f4faf52..63a270c 100644 --- a/applications/visualizer/backend/api/decorators/streaming.py +++ b/applications/visualizer/backend/api/decorators/streaming.py @@ -54,7 +54,10 @@ async def line_generator(): yield line # Return a streaming response that sends data asynchronously - return StreamingHttpResponse(line_generator(), content_type="text/plain", headers={"Content-Encoding": "identity"}) - + return StreamingHttpResponse( + line_generator(), + content_type="text/plain", + headers={"Content-Encoding": "identity"}, + ) return wrapper diff --git a/ingestion/ingestion/ingest.py b/ingestion/ingestion/ingest.py index 99002f8..7384b75 100644 --- a/ingestion/ingestion/ingest.py +++ b/ingestion/ingestion/ingest.py @@ -510,7 +510,7 @@ def trigger_populate_db(args): if line: if isinstance(line, bytes): line = line.decode("utf-8") - print(line, flush=True) + print(line, flush=True) except KeyboardInterrupt: print("\nStreaming interrupted by user.", file=sys.stderr) except Exception as e: