def _on_message_finish(self, message, **kwargs):
        self.trigger(event.RESUME, conn=self)

        self.in_flight -= 1
        try:
            self.send(protocol.finish(message.id))
        except Exception, e:
            self.close()
            self.trigger(
                event.ERROR,
                conn=self,
                error=protocol.SendError(message.id % 'failed to send FIN %s', e),
            )
dataset/ETHPy150Open nsqio/pynsq/nsq/async.py/AsyncConn._on_message_finish/swapped operands of `%`