revil-O/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

LINT fixes

Browse source
This commit is contained in:
Fabio Manganiello 2020-04-23 18:33:57 +02:00
parent d067553a3a
commit 42d29ca1f6
1 changed files with 2 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
platypush/backend/http/poll/__init__.py
View file

@ -1,12 +1,8 @@
import importlib import importlib
import time import time
from threading import Thread
from platypush.bus import Bus
from platypush.backend import Backend from platypush.backend import Backend
from platypush.backend.http.request import HttpRequest from platypush.backend.http.request import HttpRequest
from platypush.message.request import Request
class HttpPollBackend(Backend): class HttpPollBackend(Backend):
@ -60,8 +56,8 @@ class HttpPollBackend(Backend):
for request in requests: for request in requests:
if isinstance(request, dict): if isinstance(request, dict):
type = request['type'] req_type = request['type']
(module, name) = ('.'.join(type.split('.')[:-1]), type.split('.')[-1]) (module, name) = ('.'.join(req_type.split('.')[:-1]), req_type.split('.')[-1])
module = importlib.import_module(module) module = importlib.import_module(module)
request = getattr(module, name)(**request) request = getattr(module, name)(**request)
elif not isinstance(request, HttpRequest): elif not isinstance(request, HttpRequest):
@ -71,7 +67,6 @@ class HttpPollBackend(Backend):
request.bus = self.bus request.bus = self.bus
self.requests.append(request) self.requests.append(request)
def run(self): def run(self):
super().run() super().run()
@ -84,4 +79,3 @@ class HttpPollBackend(Backend):
# vim:sw=4:ts=4:et: # vim:sw=4:ts=4:et: