def _dequeueCallback3(self, job, msg):
        # Load custom function.
        if job is not None:
            if self.functions in job['function_name']:
                LOGGER.debug('Successfully pulled job off of AMQP queue')
                job['exposed_function'] = self.functions[job['function_name']]
                if not job.has_key('kwargs'):
                    job['kwargs'] = self.mapKwargs(job)
                if not job.has_key('delivery_tag'):
                    job['delivery_tag'] = msg.delivery_tag
                # If function asked for fast_cache, try to fetch it from memcache
                # while it's queued. Go ahead and add it to the queue in the meantime
                # to speed things up.
                job["reservation_fast_cache"] = None
                if self.functions[job['function_name']]["check_reservation_fast_cache"]:
                    d = self.getReservationFastCache(job['uuid'])
                    d.addCallback(self._dequeueCallback4, job)
                self.job_queue_a(job)
            else:
                LOGGER.error("Could not find function %s." % job['function_name'])
        self.pending_dequeue = False
        reactor.callLater(0, self.dequeue)
dataset/ETHPy150Open wehriam/awspider/awspider/servers2/worker.py/WorkerServer._dequeueCallback3/swapped operands of `in`