X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FMON.git;a=blobdiff_plain;f=osm_mon%2Fcollector%2Fservice.py;h=7673aedb917bfd62cd96db2c404c18e524603a4e;hp=c04f5489f38aba6a88c37a69898cfb9eee2a801a;hb=7e4cd7b78abdda2166e6f57918401350ffe0c37d;hpb=c9ee37d46cde6000c5e964532ee5aa535fdf22b0 diff --git a/osm_mon/collector/service.py b/osm_mon/collector/service.py index c04f548..7673aed 100644 --- a/osm_mon/collector/service.py +++ b/osm_mon/collector/service.py @@ -127,7 +127,10 @@ class CollectorService: processes.append(p) p.start() for process in processes: - process.join(timeout=10) + process.join(timeout=20) + for process in processes: + if process.is_alive(): + process.kill() metrics = [] while not self.queue.empty(): metrics.append(self.queue.get())