Spaces:
Sleeping
Sleeping
File size: 506 Bytes
cf450f7 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
import asyncio
import logging
import os
from . import flow
from .db import init_db
from .ingestion import ingestion_loop
logger = logging.getLogger(__name__)
async def main() -> None:
db_name = os.environ.get("DB_NAME")
if not db_name:
raise ValueError("DB_NAME environment variable is not set")
logger.info("Starting ingestion loop...")
db = init_db(True, db_name)
exe = flow.Executor(db)
await ingestion_loop(exe)
if __name__ == "__main__":
asyncio.run(main())
|