diff --git a/README.md b/README.md index 80193c5..e1ee93e 100644 --- a/README.md +++ b/README.md @@ -71,6 +71,8 @@ PYTHON_SQLITE_PATH=PathToSQLite3.db # An overwrite path to an sqllite db PYTHON_DASH_LOGIN_USERNAME=some-login-to-webgui PYTHON_DASH_LOGIN_PW=some-pw-to-login-to-webgui +PYTHON_INGEST_SCHEDULE=12 # Every x hours + CR=ghcr.io/fhswf/aki_prj23_transparenzregister TAG=latest diff --git a/src/aki_prj23_transparenzregister/apps/fetch_news.py b/src/aki_prj23_transparenzregister/apps/fetch_news.py index b92f559..434420a 100644 --- a/src/aki_prj23_transparenzregister/apps/fetch_news.py +++ b/src/aki_prj23_transparenzregister/apps/fetch_news.py @@ -1,5 +1,6 @@ """Scheduled news article extraction and transfer to MongoDB.""" import argparse +import os import sys import time @@ -45,7 +46,10 @@ def fetch_news_cli() -> None: # pragma: no cover configer_logger(namespace=parsed) config_provider = get_config_provider(parsed.config) - every(12).hours.do(schedule, config_provider) + schedule = int(os.getenv("PYTHON_INGEST_SCHEDULE", "6")) + + logger.info(f"Scheduled job will run every {schedule} hours") + every(schedule).hours.do(schedule, config_provider) while True: run_pending()