diff --git a/trustgraph-base/trustgraph/base/pubsub.py b/trustgraph-base/trustgraph/base/pubsub.py
index cd4c9394..412363f2 100644
--- a/trustgraph-base/trustgraph/base/pubsub.py
+++ b/trustgraph-base/trustgraph/base/pubsub.py
@@ -1,6 +1,7 @@
 
 import os
 import pulsar
+import _pulsar
 import uuid
 from pulsar.schema import JsonSchema