lease fix
This commit is contained in:
@@ -184,7 +184,7 @@ class Ingestor:
|
|||||||
# Get slot lease
|
# Get slot lease
|
||||||
self.ingestor_manager.get_slot_leases(available_slots)
|
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)
|
self.logger.info("Extra slots available: %s", slot_diff)
|
||||||
# There's enough slots for all ingestors, but this ingestor has more than one slot
|
# There's enough slots for all ingestors, but this ingestor has more than one slot
|
||||||
|
|||||||
Reference in New Issue
Block a user