if service_spec.service_type == 'ingress':
dds = list(dd for dd in self._get_daemons() if dd.service_name() == cast(IngressSpec, service_spec).backend_service)
dds += list(dd for dd in self._get_tmp_daemons() if dd.service_name() == cast(IngressSpec, service_spec).backend_service)
- logger.info(f'Found related daemons {dds} for service {service_spec.service_name()}')
+ logger.debug(f'Found related daemons {dds} for service {service_spec.service_name()}')
return dds
else:
for ingress_spec in [cast(IngressSpec, s) for s in self.mgr.spec_store.active_specs.values() if s.service_type == 'ingress']:
if ingress_spec.backend_service == service_spec.service_name():
dds = list(dd for dd in self._get_daemons() if dd.service_name() == ingress_spec.service_name())
dds += list(dd for dd in self._get_tmp_daemons() if dd.service_name() == ingress_spec.service_name())
- logger.info(f'Found related daemons {dds} for service {service_spec.service_name()}')
+ logger.debug(f'Found related daemons {dds} for service {service_spec.service_name()}')
return dds
return None
self.validate()
- if self.related_service_daemons:
- logger.info(f'Service {self.service_name} has related daemons already placed: {self.related_service_daemons}')
- else:
- logger.info(f'Service {self.service_name} has no related daemon already placed.')
-
count = self.spec.placement.count
# get candidate hosts based on [hosts, label, host_pattern]
if need <= 0:
break
if dp.hostname in related_service_hosts and dp.hostname not in [h.hostname for h in self.unreachable_hosts]:
- logger.info(f'Preferring {dp.hostname} for service {self.service_name} as related daemons have been placed there')
+ logger.debug(f'Preferring {dp.hostname} for service {self.service_name} as related daemons have been placed there')
to_add.append(dp)
need -= 1 # this is last use of need so it can work as a counter
# at this point, we've either met our placement quota entirely using hosts with related