revert test
This commit is contained in:
parent
8b7daaaef2
commit
daf64fc4a9
1 changed files with 3 additions and 4 deletions
|
@ -1208,12 +1208,11 @@ async def wait_for_slots_status(context,
|
|||
while True:
|
||||
async with await session.get(f'{base_url}/slots', params=params) as slots_response:
|
||||
status_code = slots_response.status
|
||||
if status_code == 503 and status_code == expected_http_status_code:
|
||||
return
|
||||
slots = await slots_response.json()
|
||||
if context.debug:
|
||||
print(f"slots responses {slots}\n")
|
||||
|
||||
if status_code == 503 and status_code == expected_http_status_code:
|
||||
return
|
||||
if status_code == 200 and status_code == expected_http_status_code:
|
||||
n_slots_idle = sum(1 if slot["state"] == 0 else 0 for slot in slots)
|
||||
n_slots_processing = sum(1 if slot["state"] != 0 else 0 for slot in slots)
|
||||
|
@ -1373,4 +1372,4 @@ def start_server_background(context):
|
|||
thread_stderr = threading.Thread(target=server_log, args=(context.server_process.stderr, sys.stderr))
|
||||
thread_stderr.start()
|
||||
|
||||
print(f"server pid={context.server_process.pid}, behave pid={os.getpid()}")
|
||||
print(f"server pid={context.server_process.pid}, behave pid={os.getpid()}")
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue