diff options
| -rw-r--r-- | src/lib/Bcfg2/Reporting/Collector.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/lib/Bcfg2/Reporting/Collector.py b/src/lib/Bcfg2/Reporting/Collector.py index 88e8f68eb..e29bd5a99 100644 --- a/src/lib/Bcfg2/Reporting/Collector.py +++ b/src/lib/Bcfg2/Reporting/Collector.py @@ -78,6 +78,7 @@ class ReportingCollector(object): self.children = [] self.cleanup_threshold = 25 + self.semaphore = None if Bcfg2.Options.setup.children > 0: self.semaphore = threading.Semaphore( value=Bcfg2.Options.setup.children) @@ -156,7 +157,7 @@ class ReportingCollector(object): interaction = self.transport.fetch() if not interaction: continue - if Bcfg2.Options.setup.children > 0: + if self.semaphore: self.semaphore.acquire() store_thread = ReportingStoreThread(interaction, self.storage, semaphore=self.semaphore) |