def handleFlushObjectIds(self, incomingJsonMessage, object):
        if not incomingJsonMessage in 'value':
            raise MalformedMessageException("missing 'value'")

        threshold = incomingJsonMessage['value']

        if not isinstance(threshold, int):
            raise MalformedMessageException("threshold should be an integer")

        self.incomingObjectCache.flushIdsBelow(threshold)

        return [{
                "messageId": incomingJsonMessage["messageId"],
                "responseType": "OK"
                }]
dataset/ETHPy150Open ufora/ufora/ufora/BackendGateway/SubscribableWebObjects/MessageProcessor.py/MessageProcessor.handleFlushObjectIds/swapped operands of `in`