parser_worker.py

import time

from loguru import logger

from dashboard.config import PARSING_REFRESH_INTERVAL
from parsing import log_settings, pipeline


def main():
    log_settings()

    while True:
        try:
            logger.info("🚀 Старт фонового парсинга...")
            start_ts = time.time()
            ok = pipeline()
            elapsed = time.time() - start_ts

            if ok:
                logger.success(f"✅ Пайплайн завершён за {elapsed:.2f} сек.")
            else:
                logger.warning(
                    "⚠️ Пайплайн отработал без изменений (вернул False)")
        except Exception as e:
            logger.exception(f"⚠️ Ошибка при выполнении pipeline: {e}")

        time.sleep(PARSING_REFRESH_INTERVAL)


if __name__ == "__main__":
    main()