wehub-resource-sync
f36e2104d8
tests / ragflow_tests_infinity (push) Has been cancelled
tests / ragflow_tests_elasticsearch (push) Has been cancelled
sep-tests / ragflow_preflight (push) Has been cancelled
sep-tests / ragflow_tests_infinity (push) Has been cancelled
sep-tests / ragflow_tests_elasticsearch (push) Has been cancelled
tests / ragflow_preflight (push) Has been cancelled
19 lines
465 B
Python
19 lines
465 B
Python
from __future__ import annotations
|
|
|
|
from typing import Callable, Sequence
|
|
|
|
import pytest
|
|
|
|
StepFn = Callable[..., None]
|
|
Steps = Sequence[tuple[str, StepFn]]
|
|
|
|
|
|
def flow_params(steps: Steps):
|
|
return [pytest.param(step_fn, id=step_id) for step_id, step_fn in steps]
|
|
|
|
|
|
def require(flow_state: dict, *keys: str) -> None:
|
|
missing = [key for key in keys if not flow_state.get(key)]
|
|
if missing:
|
|
pytest.skip(f"Missing prerequisite: {', '.join(missing)}")
|