def flush()

in assets/OfficialDemos/Others/Python/GitHubFunction.py [0:0]

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

    def flush(self):
        try:
            start = time.time()
            self.sender.send(EventData(self.buffer))
            self.flush_cb(time.time() - start, self.item_count)
        except Exception as e:
            raise EventHubError("lost the following {} records:\n {}".format(self.item_count, self.buffer))

        self.buffer = ""
        self.item_count = 0