diff --git a/common/utils/grpc_utils.py b/common/utils/grpc_utils.py
index 86abdba..b9cc8f7 100644
--- a/common/utils/grpc_utils.py
+++ b/common/utils/grpc_utils.py
@@ -20,6 +20,7 @@
 from concurrent.futures import Future
 from twisted.internet import reactor
 from twisted.internet.defer import Deferred
+from twisted.python.threadable import isInIOThread
 
 
 def twisted_async(func):
@@ -60,6 +61,10 @@
     """
     def in_thread_wrapper(*args, **kw):
 
+        if isInIOThread():
+
+            return func(*args, **kw)
+
         f = Future()
 
         def twisted_wrapper():