minor

Author: sunsingerus

main.py

@@ -20,7 +20,6 @@ class Main(Daemon):
     config = None
 
     def __init__(self):
-        mp.set_start_method('forkserver')
         self.config = CLIOpts.config()
 
         logging.basicConfig(
@@ -30,6 +29,7 @@ def __init__(self):
         )
         super().__init__(pidfile=self.config.pid_file())
         logging.debug(pprint.pformat(self.config.config))
+        mp.set_start_method('forkserver')
 
     def run(self):
         pumper = Pumper(

src/writer/processwriter.py

@@ -24,11 +24,13 @@ def open(self):
         pass
 
     def process(self, event_or_events=None):
+        logging.debug('class:%s starting process', __class__)
         writer = self.next_writer_builder.get()
         writer.insert(event_or_events)
         writer.close()
         writer.push()
         writer.destroy()
+        logging.debug('class:%s ending process', __class__)
 
     def insert(self, event_or_events=None):
         # event_or_events = [