diff --git a/acto/runner/runner.py b/acto/runner/runner.py
index 7aa75f312c..641652e3d3 100644
--- a/acto/runner/runner.py
+++ b/acto/runner/runner.py
@@ -1,7 +1,7 @@
 import base64
 import queue
 import time
-from multiprocessing import Process, Queue
+from multiprocessing import Process, Queue, set_start_method, get_start_method
 
 import yaml
 
@@ -60,6 +60,9 @@ def __init__(self,
             'role_binding': self.rbacAuthorizationV1Api.list_namespaced_role_binding,
         }
 
+        if get_start_method() != "fork":
+            set_start_method("fork")
+
     def run(self, input: dict, generation: int) -> Tuple[Snapshot, bool]:
         '''Simply run the cmd and dumps system_state, delta, operator log, events and input files without checking. 
            The function blocks until system converges.