lukmangrd/platypush
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Revert "In Python 3.7 async is a strict language keyword that can't be used for variables names - replaces occurrences with _async"

Browse source 
This reverts commit f0577733b6.
This commit is contained in:
Fabio Manganiello 2018-08-07 21:52:07 +00:00
parent b023618950
commit ee5e4dff92
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
platypush/message/request/__init__.py
View file

@ -159,12 +159,12 @@ class Request(Message):
'origin attached: {}'.format(response)) 'origin attached: {}'.format(response))
def execute(self, n_tries=1, _async=True, **context): def execute(self, n_tries=1, async=True, **context):
""" """
Execute this request and returns a Response object Execute this request and returns a Response object
Params: Params:
n_tries -- Number of tries in case of failure before raising a RuntimeError n_tries -- Number of tries in case of failure before raising a RuntimeError
_async -- If True, the request will be run asynchronously and the async -- If True, the request will be run asynchronously and the
response posted on the bus when available (default), response posted on the bus when available (default),
otherwise the current thread will wait for the response otherwise the current thread will wait for the response
to be returned synchronously. to be returned synchronously.
@ -212,7 +212,7 @@ class Request(Message):
if self.token is None or get_hash(self.token) != token_hash: if self.token is None or get_hash(self.token) != token_hash:
raise PermissionError() raise PermissionError()
if _async: if async:
Thread(target=_thread_func, args=(n_tries,)).start() Thread(target=_thread_func, args=(n_tries,)).start()
else: else:
return _thread_func(n_tries) return _thread_func(n_tries)

2
platypush/procedure/__init__.py
View file

@ -108,7 +108,7 @@ class Procedure(object):
context['async'] = self.async; context['n_tries'] = n_tries context['async'] = self.async; context['n_tries'] = n_tries
response = request.execute(**context) response = request.execute(**context)
if not self._async: if not self.async:
if isinstance(response.output, dict): if isinstance(response.output, dict):
for (k,v) in response.output.items(): for (k,v) in response.output.items():
context[k] = v context[k] = v