def valid_message_receive()

in rabbitmq/VidispineMessageProcessor.py [0:0]

• 26 lines of code
• 5 McCabe index (conditional complexity)

    def valid_message_receive(self, exchange_name, routing_key, delivery_tag, body: dict):
        """
        receives the validated vidispine json message.
        :param exchange_name:
        :param routing_key:
        :param delivery_tag:
        :param body:
        :return:
        """
        logger.debug("got incoming message: ", body)
        notification = JobNotification(body)

        importjob = ImportJob.objects.get(job_id=notification.jobId)
        importjob.status = notification.status
        importjob.processing = False
        importjob.completed_at = datetime.now(tz=pytz.timezone(time_zone))
        importjob.save()

        if importjob.is_failed():
            VidispineMessageProcessor.handle_failed_job(importjob)
        else:
            try:
                logger.info("{0}: Checking for broken proxy".format(importjob.item_id))
                should_regen, shape_id = check_for_broken_proxy(importjob.item_id)
                if should_regen:
                    logger.info("{0}: Proxy needs regen. Existing shape id is {1}".format(importjob.item_id, shape_id))
                    if shape_id is not None:
                        logger.info("{0}: Deleting invalid proxy".format(importjob.item_id))
                        delete_existing_proxy(importjob.item_id, shape_id)
                    transcode_proxy(importjob.item_id, "lowres")
                else:
                    logger.info("{0}: Proxy is OK".format(importjob.item_id))
            except Exception as e:
                logger.exception("{0}: Could not do proxy check: ", exc_info=e)
                inform_sentry_exception()
        importjob.save()