LICENSE
README.md
pyproject.toml
setup.py
src/gtfs_rt_aggregator/__init__.py
src/gtfs_rt_aggregator/adapters.py
src/gtfs_rt_aggregator/pipeline.py
src/gtfs_rt_aggregator/punctuality.py
src/gtfs_rt_aggregator.egg-info/PKG-INFO
src/gtfs_rt_aggregator.egg-info/SOURCES.txt
src/gtfs_rt_aggregator.egg-info/dependency_links.txt
src/gtfs_rt_aggregator.egg-info/entry_points.txt
src/gtfs_rt_aggregator.egg-info/requires.txt
src/gtfs_rt_aggregator.egg-info/top_level.txt
src/gtfs_rt_aggregator/aggregator/__init__.py
src/gtfs_rt_aggregator/aggregator/compaction.py
src/gtfs_rt_aggregator/aggregator/convert.py
src/gtfs_rt_aggregator/aggregator/dedup.py
src/gtfs_rt_aggregator/aggregator/fetch_times.py
src/gtfs_rt_aggregator/aggregator/paths.py
src/gtfs_rt_aggregator/aggregator/service.py
src/gtfs_rt_aggregator/aggregator/trip_stop_events.py
src/gtfs_rt_aggregator/aggregator/trip_stop_service.py
src/gtfs_rt_aggregator/config/__init__.py
src/gtfs_rt_aggregator/config/loader.py
src/gtfs_rt_aggregator/config/models.py
src/gtfs_rt_aggregator/fetcher/__init__.py
src/gtfs_rt_aggregator/fetcher/arrow_builder.py
src/gtfs_rt_aggregator/fetcher/filter.py
src/gtfs_rt_aggregator/fetcher/gtfs_rt.py
src/gtfs_rt_aggregator/fetcher/service.py
src/gtfs_rt_aggregator/runtime/__init__.py
src/gtfs_rt_aggregator/runtime/core.py
src/gtfs_rt_aggregator/runtime/runtime.py
src/gtfs_rt_aggregator/runtime/spool.py
src/gtfs_rt_aggregator/runtime/worker.py
src/gtfs_rt_aggregator/schema/__init__.py
src/gtfs_rt_aggregator/schema/alert.py
src/gtfs_rt_aggregator/schema/conform.py
src/gtfs_rt_aggregator/schema/shape.py
src/gtfs_rt_aggregator/schema/stop.py
src/gtfs_rt_aggregator/schema/trip_modifications.py
src/gtfs_rt_aggregator/schema/trip_update.py
src/gtfs_rt_aggregator/schema/vehicle_position.py
src/gtfs_rt_aggregator/sinks/__init__.py
src/gtfs_rt_aggregator/sinks/iceberg.py
src/gtfs_rt_aggregator/static/__init__.py
src/gtfs_rt_aggregator/static/service.py
src/gtfs_rt_aggregator/storage/__init__.py
src/gtfs_rt_aggregator/storage/base.py
src/gtfs_rt_aggregator/storage/factory.py
src/gtfs_rt_aggregator/storage/filesystem.py
src/gtfs_rt_aggregator/storage/gcs.py
src/gtfs_rt_aggregator/storage/minio.py
src/gtfs_rt_aggregator/utils/__init__.py
src/gtfs_rt_aggregator/utils/cleanup.py
src/gtfs_rt_aggregator/utils/cli.py
src/gtfs_rt_aggregator/utils/cpu.py
src/gtfs_rt_aggregator/utils/file_time.py
src/gtfs_rt_aggregator/utils/http.py
src/gtfs_rt_aggregator/utils/log_helper.py
src/gtfs_rt_aggregator/utils/redact.py
src/gtfs_rt_aggregator/utils/serializer.py