def handle()

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

• 15 lines of code
• 6 McCabe index (conditional complexity)

    def handle(self, *args, **options):
        if not options["server"] or not options["secret"]:
            logger.error("You must specify --server and --secret on the command line")
            sys.exit(1)

        page_size = 100
        start_at = 0

        while True:
            processed = 0
            for entry in self.next_page_of_commissions(options["server"], options["secret"], start_at, page_size):
                self.process_entry(entry)
                start_at += 1
                processed += 1
            if processed==0:
                logger.info("All done - processed {} commissions".format(start_at))
                break