fabaff/platypush
1
0
Fork 0
forked from platypush/platypush
Code Issues Pull requests Projects Releases Packages Wiki Activity

FIX: LifoQueue.get is blocking. Check if the queue is empty instead

Browse source
This commit is contained in:
Fabio Manganiello 2019-07-13 22:22:30 +02:00
parent 55cd937a51
commit 0826dd53a6
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
platypush/procedure/__init__.py
View file

@ -108,10 +108,9 @@ class Procedure(object):
request = Request.build(request_config) request = Request.build(request_config)
reqs.append(request) reqs.append(request)
while not if_config.empty():
pending_if = if_config.get() pending_if = if_config.get()
while pending_if:
reqs.append(IfProcedure.build(**pending_if)) reqs.append(IfProcedure.build(**pending_if))
pending_if = if_config.get()
return procedure_class(name=name, _async=_async, requests=reqs, args=args, backend=backend, **kwargs) return procedure_class(name=name, _async=_async, requests=reqs, args=args, backend=backend, **kwargs)