Move multiprocessing context to quixstreams.multiprocessing

Author: ovv

quixstreams/__init__.py

@@ -2,6 +2,7 @@
 from .context import message_context
 from .models import MessageContext
 from .state import State
+from .multiprocessing import multiprocessing
 
 
 __version__ = "2.9.0"

quixstreams/multiprocessing.py

@@ -0,0 +1,5 @@
+from multiprocessing import get_context
+
+# always use spawn as it's supported on all major OS
+# see https://docs.python.org/3/library/multiprocessing.html#contexts-and-start-methods
+multiprocessing = get_context("spawn")

quixstreams/sources/manager.py

@@ -2,20 +2,16 @@
 import logging
 import signal
 
-from multiprocessing import get_context
 from pickle import PicklingError
 from typing import List
 
+from quixstreams.multiprocessing import multiprocessing
 from quixstreams.logging import configure_logging, LOGGER_NAME
 from quixstreams.models import Topic
 from .base import BaseSource
 
 logger = logging.getLogger(__name__)
 
-# always use spawn as it's supported on all major OS
-# see https://docs.python.org/3/library/multiprocessing.html#contexts-and-start-methods
-multiprocessing = get_context("spawn")
-
 
 class SourceProcess(multiprocessing.Process):
     """