Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,10 @@ test-snowflake:
@echo "❄️ Running Snowflake tests..."
$(PYTHON) pytest tests/ -m "snowflake" -v --log-cli-level=ERROR

test-clickhouse:
@echo "🏠 Running ClickHouse tests..."
$(PYTHON) pytest tests/ -m "clickhouse" -v --log-cli-level=ERROR

test-lmdb:
@echo "⚡ Running LMDB tests..."
$(PYTHON) pytest tests/ -m "lmdb" -v --log-cli-level=ERROR
Expand Down Expand Up @@ -131,6 +135,7 @@ help:
@echo " make test-all - Run all tests with coverage"
@echo " make test-postgresql - Run PostgreSQL tests"
@echo " make test-redis - Run Redis tests"
@echo " make test-clickhouse - Run ClickHouse tests"
@echo " make test-snowflake - Run Snowflake tests"
@echo " make test-performance - Run performance tests"
@echo " make lint - Lint code with ruff"
Expand Down
11 changes: 11 additions & 0 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,14 @@ lmdb = [
"lmdb>=1.4.0",
]

clickhouse = [
"clickhouse-connect>=0.8.0",
]

metrics = [
"prometheus-client>=0.20.0",
]

all_loaders = [
"psycopg2-binary>=2.9.0", # PostgreSQL
"redis>=4.5.0", # Redis
Expand All @@ -75,6 +83,8 @@ all_loaders = [
"snowflake-connector-python>=4.0.0", # Snowflake
"snowpipe-streaming>=1.0.0", # Snowpipe Streaming API
"lmdb>=1.4.0", # LMDB
"clickhouse-connect>=0.8.0", # ClickHouse
"prometheus-client>=0.20.0", # Metrics
]

test = [
Expand Down Expand Up @@ -122,6 +132,7 @@ markers = [
"delta_lake: Tests requiring Delta Lake",
"iceberg: Tests requiring Apache Iceberg",
"snowflake: Tests requiring Snowflake",
"clickhouse: Tests requiring ClickHouse",
"cloud: Tests requiring cloud storage access",
]

Expand Down
7 changes: 7 additions & 0 deletions src/amp/loaders/implementations/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,11 @@
except ImportError:
LMDBLoader = None

try:
from .clickhouse_loader import ClickHouseLoader
except ImportError:
ClickHouseLoader = None

# Add any other loaders here
# try:
# from .snowflake_loader import SnowflakeLoader
Expand All @@ -55,3 +60,5 @@
__all__.append('SnowflakeLoader')
if LMDBLoader:
__all__.append('LMDBLoader')
if ClickHouseLoader:
__all__.append('ClickHouseLoader')
Loading