Remove task.run() it is hiding missing run functions

This commit is contained in:
Anders Ingemann 2013-06-27 00:30:07 +02:00
parent 1214210738
commit 237dde9285
7 changed files with 1 additions and 11 deletions

View file

@ -9,9 +9,6 @@ class Task(object):
def __init__(self): def __init__(self):
self._check_ordering() self._check_ordering()
def run(self, info):
pass
def __str__(self): def __str__(self):
return '{module}.{task}'.format(module=self.__module__, task=self.__class__.__name__) return '{module}.{task}'.format(module=self.__module__, task=self.__class__.__name__)

View file

@ -11,5 +11,4 @@ class AddSudoPackage(Task):
before = [CheckPackages] before = [CheckPackages]
def run(self, info): def run(self, info):
super(AddSudoPackage, self).run(info)
info.img_packages[0].add('sudo') info.img_packages[0].add('sudo')

View file

@ -9,5 +9,4 @@ class PrintInfo(Task):
after = [GetInfo] after = [GetInfo]
def run(self, info): def run(self, info):
super(PrintInfo, self).run(info)
print('info') print('info')

View file

@ -3,10 +3,10 @@ import base
class Manifest(base.Manifest): class Manifest(base.Manifest):
def validate(self, data): def validate(self, data):
super(Manifest, self).validate(data)
from os import path from os import path
schema_path = path.normpath(path.join(path.dirname(__file__), 'manifest-schema.json')) schema_path = path.normpath(path.join(path.dirname(__file__), 'manifest-schema.json'))
self.schema_validate(data, schema_path) self.schema_validate(data, schema_path)
super(Manifest, self).validate(data)
def parse(self, data): def parse(self, data):
super(Manifest, self).parse(data) super(Manifest, self).parse(data)

View file

@ -8,7 +8,6 @@ class GetCredentials(Task):
phase = phases.preparation phase = phases.preparation
def run(self, info): def run(self, info):
super(GetCredentials, self).run(info)
info.credentials = self.get_credentials(info.manifest) info.credentials = self.get_credentials(info.manifest)
def get_credentials(self, manifest): def get_credentials(self, manifest):
@ -35,7 +34,6 @@ class Connect(Task):
after = [GetCredentials, host.GetInfo] after = [GetCredentials, host.GetInfo]
def run(self, info): def run(self, info):
super(Connect, self).run(info)
from boto.ec2 import connect_to_region from boto.ec2 import connect_to_region
info.connection = connect_to_region(info.host['region'], info.connection = connect_to_region(info.host['region'],
aws_access_key_id=info.credentials['access_key'], aws_access_key_id=info.credentials['access_key'],

View file

@ -25,7 +25,6 @@ class GetInfo(Task):
phase = phases.preparation phase = phases.preparation
def run(self, info): def run(self, info):
super(GetInfo, self).run(info)
import urllib2 import urllib2
import json import json
metadata_url = 'http://169.254.169.254/latest/dynamic/instance-identity/document' metadata_url = 'http://169.254.169.254/latest/dynamic/instance-identity/document'

View file

@ -7,7 +7,6 @@ class HostPackages(Task):
phase = phases.preparation phase = phases.preparation
def run(self, info): def run(self, info):
super(HostPackages, self).run(info)
packages = set(['debootstrap', packages = set(['debootstrap',
# To make sure a volume is not busy before unmounting we need lsof # To make sure a volume is not busy before unmounting we need lsof
'lsof', 'lsof',
@ -23,7 +22,6 @@ class ImagePackages(Task):
phase = phases.preparation phase = phases.preparation
def run(self, info): def run(self, info):
super(ImagePackages, self).run(info)
manifest = info.manifest manifest = info.manifest
# Add some basic packages we are going to need # Add some basic packages we are going to need
include = set(['udev', include = set(['udev',