+ self.logged_jobs.intersection_update(seen_jobs)
+
+ # Make sure the server queue has at least enough entries to
+ # satisfy min_nodes.
+ node_shortfall = self.min_nodes - len(servers)
+ if node_shortfall > 0:
+ basic_node = self.cloud_size_for_constraints({})
+ servers.extend([basic_node.real] * node_shortfall)