[Ryans-MacBook-Pro] [stable/kilo:●] ~/astara git diff
diff --git a/akanda/rug/openstack/common/rpc/amqp.py b/akanda/rug/openstack/common/rpc/amqp.py
index 1cbb20f..cf4d614 100644
--- a/akanda/rug/openstack/common/rpc/amqp.py
+++ b/akanda/rug/openstack/common/rpc/amqp.py
@@ -107,7 +107,13 @@ class Pool(pools.Pool):
         self.connection_cls.pool = None


-_pool_create_sem = semaphore.Semaphore()
+class TimedSemaphore(semaphore.Semaphore):
+
+    def __enter__(self):
+        self.acquire(timeout=60)
+
+
+_pool_create_sem = TimedSemaphore()