IQ.Lvbs/pycapnp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed black issues

Browse Source 
- Disabled flake8 checks from blocking CI
- Added python 3.10 to packaging and manylinux
This commit is contained in:
Madhava Jay
2022-04-06 13:32:52 +10:00
parent d49f4a9813
commit ea70dac5cb
10 changed files with 29 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
examples/async_server.py
View File

@@ -20,13 +20,13 @@ class ExampleImpl(thread_capnp.Example.Server):
def subscribeStatus(self, subscriber, **kwargs):
return (
capnp.getTimer()
.after_delay(10 ** 9)
.after_delay(10**9)
.then(lambda: subscriber.status(True))
.then(lambda _: self.subscribeStatus(subscriber))
)
def longRunning(self, **kwargs):
return capnp.getTimer().after_delay(1 * 10 ** 9)
return capnp.getTimer().after_delay(1 * 10**9)
class Server:

4
examples/async_ssl_server.py
View File

@@ -24,13 +24,13 @@ class ExampleImpl(thread_capnp.Example.Server):
def subscribeStatus(self, subscriber, **kwargs):
return (
capnp.getTimer()
.after_delay(10 ** 9)
.after_delay(10**9)
.then(lambda: subscriber.status(True))
.then(lambda _: self.subscribeStatus(subscriber))
)
def longRunning(self, **kwargs):
return capnp.getTimer().after_delay(1 * 10 ** 9)
return capnp.getTimer().after_delay(1 * 10**9)
def alive(self, **kwargs):
return True

4
examples/thread_server.py
View File

@@ -14,13 +14,13 @@ class ExampleImpl(thread_capnp.Example.Server):
def subscribeStatus(self, subscriber, **kwargs):
return (
capnp.getTimer()
.after_delay(10 ** 9)
.after_delay(10**9)
.then(lambda: subscriber.status(True))
.then(lambda _: self.subscribeStatus(subscriber))
)
def longRunning(self, **kwargs):
return capnp.getTimer().after_delay(1 * 10 ** 9)
return capnp.getTimer().after_delay(1 * 10**9)
def parse_args():