Flake8 fixes
This commit is contained in:
parent
a333370532
commit
6b7d25cedc
2
.flake8
2
.flake8
|
@ -1,3 +1,3 @@
|
|||
[flake8]
|
||||
max-line-length = 120
|
||||
ignore = E402,W503,W504,D
|
||||
ignore = E402,W503,W504,D,F405
|
||||
|
|
|
@ -124,6 +124,19 @@ def media_stop(rtc: object) -> None:
|
|||
assert ret.status_code == 204, f'{ret.status_code} returned'
|
||||
|
||||
|
||||
def load_service_sequential(self) -> None:
|
||||
print_text('Load_and_process_service_sequential')
|
||||
items = requests.get(f'http://{self.address}:{self.http_port}/api/v2/service/items')
|
||||
service = json.loads(items.text)
|
||||
# test sequentially
|
||||
for item in service:
|
||||
if item['plugin'] == 'video':
|
||||
pass
|
||||
else:
|
||||
self.tasks.append(Task(self, service_item_show, poll_m=1, poll_o=2))
|
||||
self.tasks.append(Task(self, play_live_item, poll_m=1, poll_o=2))
|
||||
|
||||
|
||||
def service_item_show(rtc: object, item: dict) -> None:
|
||||
print_text('Service_item_show')
|
||||
title = item['title']
|
||||
|
@ -131,11 +144,10 @@ def service_item_show(rtc: object, item: dict) -> None:
|
|||
print_text(f'test_service_song {title} {id}')
|
||||
ret = requests.post(rtc.base_url + 'service/show', json=dict(uid=id))
|
||||
assert ret.status_code == 204, ret.status_code
|
||||
check_websocket_changes(rtc, 1, 2)
|
||||
live_item(rtc, item['plugin'])
|
||||
|
||||
|
||||
def live_item(rtc: object, plugin: str) -> None:
|
||||
def play_live_item(rtc: object, plugin: str) -> None:
|
||||
print_text(f'test_live_item - {plugin}')
|
||||
ret = requests.get(rtc.base_url + 'controller/live-item')
|
||||
assert ret.status_code == 200, f'{ret.status_code} returned from live_item'
|
||||
|
@ -145,9 +157,3 @@ def live_item(rtc: object, plugin: str) -> None:
|
|||
i += 1
|
||||
human_delay()
|
||||
assert ret.status_code == 204, f'{ret.status_code} returned from show'
|
||||
if plugin in {'image'}:
|
||||
check_websocket_changes(rtc, 0, 0)
|
||||
else:
|
||||
check_websocket_changes(rtc, 1, 2)
|
||||
|
||||
|
||||
|
|
|
@ -178,16 +178,7 @@ class RunTestsController(object):
|
|||
self.tasks.append(Task(self, clear_preview_controller, delay=1))
|
||||
self.tasks.append(Task(self, new_service, poll_m=1, poll_o=1))
|
||||
|
||||
def load_service_sequential(self) -> None:
|
||||
print_text('Load_and_process_service_sequential')
|
||||
items = requests.get(f'http://{self.address}:{self.http_port}/api/v2/service/items')
|
||||
service = json.loads(items.text)
|
||||
# test sequentially
|
||||
for item in service:
|
||||
if item['plugin'] == 'video':
|
||||
pass
|
||||
else:
|
||||
service_item_show(self, item)
|
||||
|
||||
|
||||
def load_service_random(self) -> None:
|
||||
print_text('Load_and process_service_random')
|
||||
|
|
Loading…
Reference in New Issue