diff options
Diffstat (limited to 'bitbake/lib/prserv/client.py')
-rw-r--r-- | bitbake/lib/prserv/client.py | 20 |
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 | ||
12 | class PRAsyncClient(bb.asyncrpc.AsyncClient): | 12 | class 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 | ||
44 | class PRClient(bb.asyncrpc.Client): | 44 | class 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() |