

def process_messages(self, msgs):
    for received_message in msgs:
        pubsub_message = received_message.get('message')
        log.debug(('processing %s' % received_message.get('ackId')))
        if pubsub_message:
            ack_ids = []
            cmd_retcode = self.run_task(received_message)
            ack_ids.append(received_message.get('ackId'))
            ack_body = {
                'ackIds': ack_ids,
            }
            if ack_ids:
                log.debug(('acking %s' % ack_ids))
                ack_resp = self.client.projects().subscriptions().acknowledge(subscription=cmd_retcode.sub['name'], body=ack_body).execute()

dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py Executor.process_messages/VarMisuse@120/184 `self`->`cmd_retcode`