Move host task to common tasks

common/tasks/host.py

@@ -18,12 +18,3 @@ class CheckPackages(Task):
 			except CalledProcessError:
 				msg = "The package ``{0}\'\' is not installed".format(package)
 				raise TaskError(msg)
-
-
-class GetInfo(Task):
-	description = 'Retrieving instance metadata'
-	phase = phases.preparation
-
-	def run(self, info):
-		info.host = {}
-		return info

providers/ec2/__init__.py

@@ -3,6 +3,7 @@ import logging
 from tasks import packages
 from tasks import connection
 from tasks import host
+from common.tasks import host as common_host
 from tasks import ami
 from tasks import ebs
 from common.tasks import loopback
@@ -27,7 +28,7 @@ def initialize():
 def tasks(tasklist, manifest):
 	tasklist.add(packages.HostPackages(),
 	             packages.ImagePackages(),
-	             host.CheckPackages(),
+	             common_host.CheckPackages(),
 	             connection.GetCredentials(),
 	             host.GetInfo(),
 	             ami.AMIName(),

providers/ec2/tasks/host.py

@@ -1,23 +1,5 @@
 from base import Task
 from common import phases
-from common.exceptions import TaskError
-import packages
-
-
-class CheckPackages(Task):
-	description = 'Checking installed host packages'
-	phase = phases.preparation
-	after = [packages.HostPackages, packages.ImagePackages]
-
-	def run(self, info):
-		from common.tools import log_check_call
-		from subprocess import CalledProcessError
-		for package in info.host_packages:
-			try:
-				log_check_call(['/usr/bin/dpkg', '-s', package])
-			except CalledProcessError:
-				msg = "The package ``{0}\'\' is not installed".format(package)
-				raise TaskError(msg)
 
 
 class GetInfo(Task):

providers/raw/__init__.py

@@ -20,8 +20,7 @@ def initialize():
 def tasks(tasklist, manifest):
 	tasklist.add(packages.HostPackages(),
 	             packages.ImagePackages(),
-	             host.CheckPackages(),
+	             host.CheckPackages())
-	             host.GetInfo())
 	tasklist.add(filesystem.FormatVolume())
 	if manifest.volume['filesystem'].lower() == 'xfs':
 		tasklist.add(filesystem.AddXFSProgs())