

def create_subscription(self, deadline=60):
    log.debug('creating subscription')
    body = {
        'topic': 'projects/{}/topics/{}'.format(self.project, self.topic),
        'ackDeadlineSeconds': deadline,
    }
    try:
        subscription = self.client.projects().subscriptions().create(name='projects/{}/subscriptions/{}'.format(self.project, self.subname), body=body).execute()
    except Exception as e:
        log.critical('unable to create subscription')
        raise
    return body

dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py Executor.create_subscription/VarMisuse@111/143 `subscription`->`body`