def process_entry()

in rabbitmq/management/commands/resync_cached_commissions.py [0:0]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    def process_entry(self, entry:dict):
        """
        handle a raw data structure from pluto-core
        :param entry:
        :return:
        """
        serializer = CachedCommissionSerializer(data=entry)
        if not serializer.is_valid():
            logger.warning("Data for {} was not valid".format(entry))
            return

        commission = CachedCommission(**serializer.validated_data)
        logger.debug("updating cachedcommission {}".format(commission.title))
        commission.save()