in cdsresponder/rabbitmq/K8MessageProcessor.py [0:0]
def retry_count(self)->Optional[int]:
value = self._content["retry-count"]
if value is not None:
try:
return int(value)
except ValueError:
logger.warning("invalid retry count data '{0}' is not a number".format(value))
return None
else:
return None