diff --git a/manifests/init.pp b/manifests/init.pp
index 743707d..5e2302d 100644
--- a/manifests/init.pp
+++ b/manifests/init.pp
@@ -33,12 +33,6 @@ class subunit2sql (
     require  => Class['pip'],
   }
 
-  package {'paho-mqtt':
-    ensure   => latest,
-    provider => openstack_pip,
-    require  => Class['pip'],
-  }
-
   package { 'subunit2sql':
     ensure   => latest,
     provider => openstack_pip,
diff --git a/manifests/worker.pp b/manifests/worker.pp
index 1873f24..96b4bb9 100644
--- a/manifests/worker.pp
+++ b/manifests/worker.pp
@@ -31,6 +31,13 @@ define subunit2sql::worker (
       ensure => absent,
     }
   }
+  if ! defined(Package['paho-mqtt']) {
+    package {'paho-mqtt':
+      ensure   => latest,
+      provider => openstack_pip,
+      require  => Class['pip'],
+    }
+  }
 
   if ! defined(User['subunit']) {
     user { 'subunit':