diff libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py @ 4270:0d7bb4df2343

Reformatted code base using black.
author Goffi <goffi@goffi.org>
date Wed, 19 Jun 2024 18:44:57 +0200
parents 26b7ed2817da
children
line wrap: on
line diff
--- a/libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py	Tue Jun 18 12:06:45 2024 +0200
+++ b/libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py	Wed Jun 19 18:44:57 2024 +0200
@@ -48,9 +48,7 @@
             pass
         else:
             raise exceptions.InternalError(
-                "{name} signal handler has been registered twice".format(
-                    name=method_name
-                )
+                "{name} signal handler has been registered twice".format(name=method_name)
             )
         setattr(self, method_name, handler)
 
@@ -70,8 +68,7 @@
         """Convert Failure to BridgeException"""
         ori_errback(
             BridgeException(
-                name=failure_.type.decode('utf-8'),
-                message=str(failure_.value)
+                name=failure_.type.decode("utf-8"), message=str(failure_.value)
             )
         )
 
@@ -167,11 +164,13 @@
 
 ##METHODS_PART##
 
+
 class AIOSignalsHandler(SignalsHandler):
 
     def register_signal(self, name, handler, iface="core"):
         async_handler = lambda *args, **kwargs: defer.Deferred.fromFuture(
-            asyncio.ensure_future(handler(*args, **kwargs)))
+            asyncio.ensure_future(handler(*args, **kwargs))
+        )
         return super().register_signal(name, async_handler, iface)
 
 
@@ -183,9 +182,8 @@
     def _errback(self, failure_):
         """Convert Failure to BridgeException"""
         raise BridgeException(
-            name=failure_.type.decode('utf-8'),
-            message=str(failure_.value)
-            )
+            name=failure_.type.decode("utf-8"), message=str(failure_.value)
+        )
 
     def call(self, name, *args, **kwargs):
         d = self.root.callRemote(name, *args, *kwargs)
@@ -196,4 +194,5 @@
         d = super().bridge_connect(callback=None, errback=None)
         return await d.asFuture(asyncio.get_event_loop())
 
+
 ##ASYNC_METHODS_PART##