diff --git a/requirements.txt b/requirements.txt index c46cb06..8520887 100644 --- a/requirements.txt +++ b/requirements.txt @@ -10,3 +10,4 @@ tqdm prometheus-clien redis minio +schedule==1.* diff --git a/src/local/__init__.py b/src/local/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/src/local/scheduler.py b/src/local/scheduler.py new file mode 100644 index 0000000..bf3a3ec --- /dev/null +++ b/src/local/scheduler.py @@ -0,0 +1,17 @@ +import schedule +import time +from src.infra.lambdas.RSSQueueFiller.lambda.lambda_function import handler + + +def run_queue_filler(): + """Invoke the queue filler lambda logic.""" + handler(None, None) + + +schedule.every(4).hours.do(run_queue_filler) + + +if __name__ == "__main__": + while True: + schedule.run_pending() + time.sleep(1)