in message_flow/messaging/common/message.py [0:0]
def get_required_header(self, name: str) -> str:
value = self._headers.get(name)
if value is None:
raise HeaderNotFound(f"No such header: {name} in this message {self}")
return value