Philipp/aki_prj23_transparenzregister
Philipp/aki_prj23_transparenzregister
1
0
Fork 0
mirror of https://github.com/fhswf/aki_prj23_transparenzregister.git synced 2025-04-22 16:32:53 +02:00
Code Issues Packages Projects Releases Wiki Activity

checkpoint: Set schedule interval via ENV variable

Browse Source
This commit is contained in:
TrisNol 2023-11-13 19:54:29 +01:00
parent 2da3e6cea0
commit 92489e7ef6
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -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_USERNAME=some-login-to-webgui
PYTHON_DASH_LOGIN_PW=some-pw-to-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 CR=ghcr.io/fhswf/aki_prj23_transparenzregister
TAG=latest TAG=latest

6
src/aki_prj23_transparenzregister/apps/fetch_news.py
View File

@ -1,5 +1,6 @@
"""Scheduled news article extraction and transfer to MongoDB.""" """Scheduled news article extraction and transfer to MongoDB."""
import argparse import argparse
import os
import sys import sys
import time import time
@ -45,7 +46,10 @@ def fetch_news_cli() -> None: # pragma: no cover
configer_logger(namespace=parsed) configer_logger(namespace=parsed)
config_provider = get_config_provider(parsed.config) 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: while True:
run_pending() run_pending()