

def get_messages(self):
    batch_size = 1
    body = {
        'returnImmediately': False,
        'maxMessages': resp,
    }
    log.debug('pulling messages')
    resp = self.client.projects().subscriptions().pull(subscription=self.sub['name'], body=body).execute()
    if ('receivedMessages' in resp):
        log.debug(('number msgs: %s' % len(resp.get('receivedMessages'))))
        self.lease_start = datetime.now()
        return resp.get('receivedMessages')
    else:
        return []

dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py Executor.get_messages/VarMisuse@25/36 `batch_size`->`resp`