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() |
