1 files changed, 13 insertions, 6 deletions

diff --git a/gnunet/dht.py b/gnunet/dht.py
index b97c7a1..e9aa525 100644
--- a/gnunet/dht.py
+++ b/gnunet/dht.py
@@ -30,9 +30,12 @@ class GetResult(threading.Thread):
 
         if request:
             if request.record_route:
-                request.callback(self.block_type, self.key, self.data, self.expiry, get_path=self.get_path, put_path=self.put_path)
+                request.callback(self.block_type, self.key, self.data,
+                                 self.expiry, get_path=self.get_path,
+                                 put_path=self.put_path)
             else:
-                request.callback(self.block_type, self.key, self.data, self.expiry)
+                request.callback(self.block_type, self.key, self.data,
+                                 self.expiry)
 
 
 def _result(expiry, key, get_path, put_path, block_type, data, path):
@@ -44,7 +47,8 @@ def _result(expiry, key, get_path, put_path, block_type, data, path):
     data = bytearray(data)
     GetResult(expiry, key, get_path, put_path, block_type, data, path)
 
-sysbus.add_signal_receiver(_result, "result", "gnu.gnunet.dht.get", "gnu.gnunet.dht", path_keyword="path")
+sysbus.add_signal_receiver(_result, "result", "gnu.gnunet.dht.get",
+                           "gnu.gnunet.dht", path_keyword="path")
 
 
 class GetRequest:
@@ -54,7 +58,8 @@ class GetRequest:
         self.record_route = record_route
 
     def filter_known_results(self, keys):
-        keys = dbus.Array([dbusize(HashCode(key)) for key in list(keys)], signature="v")
+        keys = dbus.Array([dbusize(HashCode(key))
+                           for key in list(keys)], signature="v")
         try:
             sysbus.get_object("gnu.gnunet.dht", self._path).filter_known_results(keys, dbus_interface="gnu.gnunet.dht.get")
         except dbus.DBusException as e:
@@ -67,7 +72,8 @@ class GetRequest:
             handle_exception(e, "dht", "gnu.gnunet.dht")
 
 
-def put(key, desired_replication_level, block_type, data, expiry=None, demultiplex_everywhere=False, record_route=False, bart=False):
+def put(key, desired_replication_level, block_type, data, expiry=None,
+        demultiplex_everywhere=False, record_route=False, bart=False):
     key = dbusize(HashCode(key), True)
     desired_replication_level = dbus.UInt32(desired_replication_level)
     if block_type not in block.TYPES:
@@ -94,7 +100,8 @@ def put(key, desired_replication_level, block_type, data, expiry=None, demultipl
         handle_exception(e, "dht", "gnu.gnunet.dht")
 
 
-def get_start(callback, block_type, key, desired_replication_level, demultiplex_everywhere=False, record_route=False, bart=False):
+def get_start(callback, block_type, key, desired_replication_level,
+              demultiplex_everywhere=False, record_route=False, bart=False):
     if block_type not in block.TYPES:
         raise ValueError("'block_type' must be one of %s" % block.TYPES)
     block_type = dbus.String(block_type, variant_level=1)