did stuff

This commit is contained in:
2021-12-12 02:07:26 +01:00
parent 0765d98c1f
commit 2e8a4d25b4
3 changed files with 50 additions and 6 deletions

View File

@@ -1,14 +1,31 @@
#!/usr/bin/env pyton3
import logging
import sys
from typing import Dict
import sentry_sdk
from sentry_sdk.integrations.logging import LoggingIntegration
from config import Config
from apscheduler.schedulers.blocking import BlockingScheduler
from run_scheduler import run
import redis
import json
import run_scheduler
from functools import cache
@cache
def get_site_url_map() -> Dict[str, str]:
return {p.name: p.baseurl for p in Config.SITE_LIST}
def put_site_url_map_into_redis(redis_client: redis.Redis):
redis_client.set("SITEURLMAP", json.dumps(get_site_url_map()).encode('utf-8'))
def run_wrapper(redis_client: redis.Redis):
put_site_url_map_into_redis(redis_client)
run_scheduler.run(redis_client, get_site_url_map())
def main():
@@ -34,8 +51,11 @@ def main():
level=logging.DEBUG if Config.DEBUG else logging.INFO
)
redis_client = redis.from_url(Config.REDIS_URL)
put_site_url_map_into_redis(redis_client)
scheduler = BlockingScheduler()
scheduler.add_job(run, trigger='interval', seconds=Config.INTERVAL)
scheduler.add_job(lambda: run_wrapper(redis_client), trigger='interval', seconds=Config.INTERVAL)
try:
scheduler.start()
except KeyboardInterrupt: