Function wait_for_long_task

tests/tasks.py:65–69

Waits for a long task to start.

()

def wait_for_long_task():
    """Waits for a long task to start."""
    with redis.Redis(host=REDIS_HOST, db=TEST_DB, decode_responses=True) as conn:
        result = conn.blpop(LONG_TASK_SIGNAL_KEY, int(ceil(DELAY * 3)))
    assert result[1] == "1"


@tiger.task(unique=True)