def _get_request_callback(self, message_data, message):
        #print "message_data=%s" % message_data
        drivers=[]
        drivers.append(message_data)
        DRIVER_KEY="driver_routing_key"
        TAGS_KEY="tags"
        for obj in drivers:
            driver = None
            if obj in DRIVER_KEY and TAGS_KEY in obj :
                module_name = obj["driver_routing_key"]
                try:
                    __import__(module_name)
                    module = sys.modules[module_name]
                    driver = module.Driver()
                except:
                    print "could not import module %s" % module_name
                values = []
                for tag in obj['tags']:
                    if driver:
                        value = driver.read_value(tag['device'], tag['address'])
                    else:
                        value="BAD_DRIVER"
                    values.append({'name':tag['name'],
                            'current_value':value, 
                            'read_at':'2009-01-01'})
                self.publisher.send(values)
            else:
                print "Badly formated request %s" % obj            
        message.ack()
dataset/ETHPy150Open kmpm/django-collector/collector/worker.py/Worker._get_request_callback/swapped operands of `in`