Skip to content

Commit d5ee242

Browse files
committed
fix logging
1 parent 7fd5d31 commit d5ee242

File tree

1 file changed

+5
-1
lines changed
  • backend/onyx/background/celery/tasks/indexing

1 file changed

+5
-1
lines changed

backend/onyx/background/celery/tasks/indexing/tasks.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import multiprocessing
22
import os
3+
import re
34
import time
45
import traceback
56
from datetime import datetime
@@ -109,7 +110,7 @@ class IndexingWatchdogTerminalStatus(str, Enum):
109110

110111
OUT_OF_MEMORY = "out_of_memory"
111112

112-
PROCESS_SIGNAL_SIGKILL = "process_signal_sigkill"
113+
PROCESS_SIGNAL_SIGILL = "process_signal_sigkill"
113114

114115
@property
115116
def code(self) -> int:
@@ -188,6 +189,9 @@ def build(self, msg: str, **kwargs: Any) -> str:
188189
extra_logfmt = " ".join(f"{key}={value}" for key, value in kwargs.items())
189190
msg_final = f"{msg_final} {extra_logfmt}"
190191

192+
# Ensure final log line has no newline/carriage-return characters
193+
msg_final = re.sub(r"[\r\n]+", " ", msg_final)
194+
191195
return msg_final
192196

193197

0 commit comments

Comments
 (0)