Merge pull request #83 from martinghunt/multiprocessing_bugs

Stop returning error when all clusters successful

ariba/cluster.py

@@ -134,14 +134,9 @@ def __init__(self,
 
 
     def _atexit(self):
-        print('Error in cluster', self.name, '... Stopping!', file=sys.stderr, flush=True)
         if self.log_fh is not None:
             pyfastaq.utils.close(self.log_fh)
             self.log_fh = None
-        if self.fail_file is not None:
-            with open(self.fail_file, 'w') as f:
-                pass
-        os._exit(1)
 
 
     def _receive_signal(self, signum, stack):
@@ -434,3 +429,4 @@ def _run(self):
         print('\nMaking report lines', file=self.log_fh, flush=True)
         self.report_lines = report.report_lines(self)
         self._clean()
+        atexit.unregister(self._atexit)