summaryrefslogtreecommitdiffstats
path: root/bitbake/lib/prserv/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'bitbake/lib/prserv/client.py')
-rw-r--r--bitbake/lib/prserv/client.py20
1 files changed, 10 insertions, 10 deletions
diff --git a/bitbake/lib/prserv/client.py b/bitbake/lib/prserv/client.py
index 6b81356fac..7bc5188c53 100644
--- a/bitbake/lib/prserv/client.py
+++ b/bitbake/lib/prserv/client.py
@@ -11,40 +11,40 @@ logger = logging.getLogger("BitBake.PRserv")
11 11
12class PRAsyncClient(bb.asyncrpc.AsyncClient): 12class PRAsyncClient(bb.asyncrpc.AsyncClient):
13 def __init__(self): 13 def __init__(self):
14 super().__init__('PRSERVICE', '1.0', logger) 14 super().__init__("PRSERVICE", "1.0", logger)
15 15
16 async def getPR(self, version, pkgarch, checksum): 16 async def getPR(self, version, pkgarch, checksum):
17 response = await self.invoke( 17 response = await self.invoke(
18 {'get-pr': {'version': version, 'pkgarch': pkgarch, 'checksum': checksum}} 18 {"get-pr": {"version": version, "pkgarch": pkgarch, "checksum": checksum}}
19 ) 19 )
20 if response: 20 if response:
21 return response['value'] 21 return response["value"]
22 22
23 async def importone(self, version, pkgarch, checksum, value): 23 async def importone(self, version, pkgarch, checksum, value):
24 response = await self.invoke( 24 response = await self.invoke(
25 {'import-one': {'version': version, 'pkgarch': pkgarch, 'checksum': checksum, 'value': value}} 25 {"import-one": {"version": version, "pkgarch": pkgarch, "checksum": checksum, "value": value}}
26 ) 26 )
27 if response: 27 if response:
28 return response['value'] 28 return response["value"]
29 29
30 async def export(self, version, pkgarch, checksum, colinfo): 30 async def export(self, version, pkgarch, checksum, colinfo):
31 response = await self.invoke( 31 response = await self.invoke(
32 {'export': {'version': version, 'pkgarch': pkgarch, 'checksum': checksum, 'colinfo': colinfo}} 32 {"export": {"version": version, "pkgarch": pkgarch, "checksum": checksum, "colinfo": colinfo}}
33 ) 33 )
34 if response: 34 if response:
35 return (response['metainfo'], response['datainfo']) 35 return (response["metainfo"], response["datainfo"])
36 36
37 async def is_readonly(self): 37 async def is_readonly(self):
38 response = await self.invoke( 38 response = await self.invoke(
39 {'is-readonly': {}} 39 {"is-readonly": {}}
40 ) 40 )
41 if response: 41 if response:
42 return response['readonly'] 42 return response["readonly"]
43 43
44class PRClient(bb.asyncrpc.Client): 44class PRClient(bb.asyncrpc.Client):
45 def __init__(self): 45 def __init__(self):
46 super().__init__() 46 super().__init__()
47 self._add_methods('getPR', 'importone', 'export', 'is_readonly') 47 self._add_methods("getPR", "importone", "export", "is_readonly")
48 48
49 def _get_async_client(self): 49 def _get_async_client(self):
50 return PRAsyncClient() 50 return PRAsyncClient()