

def executeJobs(self, data=None):
    while ((len(self.job_queue) > 0) and (len(self.active_jobs) < self.simultaneous_jobs)):
        job = self.job_queue.pop(0)
        exposed_function = job['exposed_function']
        kwargs = job['kwargs']
        function_name = job['function_name']
        uuid = job['uuid']
        del self.queued_jobs[uuid]
        LOGGER.debug(('Calling %s with args %s' % (function_name, kwargs)))
        d = self.callExposedFunction(exposed_function['function'], kwargs, self, uuid=uuid, reservation_fast_cache=job['reservation_cache'])
        d.addCallback(self._jobCountCallback)
        d.addErrback(self._jobCountErrback)
        d.addCallback(self._setNextRequest, uuid, exposed_function['interval'], function_name)

dataset/ETHPy150Open wehriam/awspider/awspider/servers/execution.py ExecutionServer.executeJobs/VarMisuse@118/171 `function_name`->`self`