diff --git a/ingestor/ingestor.py b/ingestor/ingestor.py index 4c7536e..166367f 100644 --- a/ingestor/ingestor.py +++ b/ingestor/ingestor.py @@ -184,7 +184,7 @@ class Ingestor: # Get slot lease self.ingestor_manager.get_slot_leases(available_slots) - elif lacking_ingestors == 0 and slot_diff > 0: + elif lacking_ingestors <= 0 and slot_diff > 0: self.logger.info("Extra slots available: %s", slot_diff) # There's enough slots for all ingestors, but this ingestor has more than one slot