22 lines
595 B
Python
22 lines
595 B
Python
|
"""Integration tests for data pipeline."""
|
||
|
|
|
||
|
|
import pytest
|
||
|
|
from src.data.collector import get_data_collector
|
||
|
|
from src.data.storage import get_data_storage
|
||
|
|
|
||
|
|
|
||
|
|
@pytest.mark.integration
|
||
|
|
class TestDataPipeline:
|
||
|
|
"""Integration tests for data collection and storage."""
|
||
|
|
|
||
|
|
@pytest.mark.asyncio
|
||
|
|
async def test_data_collection_storage(self):
|
||
|
|
"""Test data collection and storage pipeline."""
|
||
|
|
collector = get_data_collector()
|
||
|
|
storage = get_data_storage()
|
||
|
|
|
||
|
|
# Test components exist
|
||
|
|
assert collector is not None
|
||
|
|
assert storage is not None
|
||
|
|
|