"""
Data ingestion pipelines.
"""