status-mobile/test/appium/tests/__init__.py

import asyncio
import functools
import json
import os
import time
from datetime import datetime

from urllib3.exceptions import MaxRetryError

from support.test_data import TestSuiteData


async def start_threads(test_name: str, quantity: int, func: type, returns: dict, **kwargs):
    loop = asyncio.get_event_loop()
    for i in range(quantity):
        returns[i] = loop.run_in_executor(None, functools.partial(func, **kwargs))
    for k in returns:
        for _ in range(3):
            try:
                returns[k] = await returns[k]
                break
            except MaxRetryError:
                print("MaxRetryError when creating a driver for %s" % test_name)
                time.sleep(10)
    return returns


async def run_in_parallel(funcs):
    loop = asyncio.get_event_loop()
    res = []
    returns = []
    for func in funcs:
        try:
            res.append(loop.run_in_executor(None, functools.partial(func[0], **func[1])))
        except IndexError:
            res.append(loop.run_in_executor(None, func[0]))
    for k in res:
        returns.append(await k)
    return returns


def get_current_time():
    return datetime.now().strftime('%-m%-d%-H%-M%-S')


pytest_config_global = dict()
test_suite_data = TestSuiteData()

common_password = 'qwerty1234'

emojis = {'thumbs-up': 2, 'thumbs-down': 3, 'love': 1, 'laugh': 4, 'angry': 6, 'sad': 5}

with open(os.sep.join(__file__.split(os.sep)[:-1]) + '/../../../translations/en.json') as json_file:
    transl = json.load(json_file)