highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-04-03 09:28:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

log all start methods

Browse Source
This commit is contained in:
Richard Kuo (Danswer) 2025-01-10 12:11:33 -08:00
parent 8e25c3c412
commit ac182c74b3
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
backend/onyx/background/celery/apps/indexing.py
View File

@ -57,6 +57,10 @@ def on_celeryd_init(sender: Any = None, conf: Any = None, **kwargs: Any) -> None
@worker_init.connect
def on_worker_init(sender: Any, **kwargs: Any) -> None:
logger.info("worker_init signal received.")
all_start_methods: list[str] = multiprocessing.get_all_start_methods()
logger.info(f"Multiprocessing all start methods: {all_start_methods}")
multiprocessing.set_start_method("spawn") # fork is unsafe, set to spawn
logger.info(f"Multiprocessing start method: {multiprocessing.get_start_method()}")