

def extend_lease(self, msg):
    body = {
        'ackId': msg['ackId'],
        'ackDeadlineSeconds': self.ackdeadline,
    }
    resp = self.client.projects().subscriptions().modifyAckDeadline(subscription=self.sub['name'], body=body).execute()
    return resp

dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py Executor.extend_lease/original