diff --git a/goblin/app.py b/goblin/app.py
index 1b2eec2f82b44ddd8240215a5cd2fa33ec3508c4..8f87bb7950f3f6f40c706f0497c285bb6525c0b9 100644
--- a/goblin/app.py
+++ b/goblin/app.py
@@ -58,9 +58,11 @@ class Goblin:
         self._get_hashable_id = get_hashable_id
 
     @classmethod
-    async def open(cls, loop, *, get_hashable_id=None, **config):
+    async def open(cls, loop, *, get_hashable_id=None, traversal_source=None,
+                   **config):
         cluster = await driver.Cluster.open(loop, **config)
-        app = Goblin(cluster, get_hashable_id=get_hashable_id)
+        app = Goblin(cluster, get_hashable_id=get_hashable_id,
+                     traversal_source=traversal_source)
         await app.supports_transactions()
         return app
 
diff --git a/goblin/driver/connection.py b/goblin/driver/connection.py
index 65c72451aab661da0d6efedef01d96837c9fbcdb..2196390f5ce00ad61257f6c9b94925856c83accf 100644
--- a/goblin/driver/connection.py
+++ b/goblin/driver/connection.py
@@ -208,6 +208,7 @@ class Connection(AbstractConnection):
         request_id = str(uuid.uuid4())
         message = self._message_serializer.serialize_message(
             request_id, processor, op, **args)
+        logger.debug(message)
         response_queue = asyncio.Queue(loop=self._loop)
         self._response_queues[request_id] = response_queue
         if self._ws.closed: