def get_messages(self):
        # You can fetch multiple messages with a single API call.
        batch_size = 1

        # Create a POST body for the Pub/Sub request
        body = {
            # Setting ReturnImmediately to false instructs the API to wait
            # to collect the message up to the size of MaxEvents, or until
            # the timeout (approx 90s)
            'returnImmediately': False,
            'maxMessages': batch_size,
        }
        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/operator `%` -> `-`