def _get_correlation_headers()

in message_flow/commands/consumer/command_handler_params.py [0:0]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    def _get_correlation_headers(self, headers: Dict[str, str]) -> Dict[str, str]:
        correlation_headers: Dict[str, str] = {
            CommandMessageHeaders.in_reply(key): value
            for key, value in headers.items()
            if key.startswith(CommandMessageHeaders.COMMAND_HEADER_PREFIX)
        }
        correlation_headers[ReplyMessageHeaders.IN_REPLY_TO] = headers.get(
            IMessage.ID, ""
        )
        return correlation_headers