def accept()

in aws_embedded_metrics/sinks/agent_sink.py [0:0]

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

    def accept(self, context: MetricsContext) -> None:
        context.meta["LogGroupName"] = self.log_group_name
        if self.log_steam_name is not None:
            context.meta["LogStreamName"] = self.log_steam_name

        log.info(
            "Parsed agent endpoint (%s) %s:%s",
            self.endpoint.scheme,
            self.endpoint.hostname,
            self.endpoint.port,
        )
        for serialized_content in self.serializer.serialize(context):
            message = serialized_content + "\n"
            self.client.send_message(message.encode('utf-8'))