def test_query_e2e(tmp_dir, catalog_tmpfile, monkeypatch):
    """End-to-end CLI Query Test"""
    monkeypatch.delenv("DATACHAIN_DISTRIBUTED", raising=False)
    for step in E2E_STEPS:
        run_step(step, catalog_tmpfile)
End-to-end CLI Query Test
tests/test_query_e2e.py