def log_metrics()

in lambda/api/experiment_metrics.py [0:0]

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

    def log_metrics(self, metrics):
        # Update metrics directly in DDB if required.
        if self.synchronous:
            return self.update_variant_metrics(metrics)

        # Dump the results as a json lines with trailing new line
        event_log = "\n".join([json.dumps(metric) for metric in metrics]) + "\n"
        logging.debug("Log kinesis events")
        logging.debug(event_log)

        # Put to delivery stream
        return self.firehose.put_record(
            DeliveryStreamName=self.delivery_stream_name,
            Record={"Data": event_log.encode("utf-8")},
        )