From 5e41da6e712dc273eb387bd08b4c5a4fede6f761 Mon Sep 17 00:00:00 2001
From: PAN Lei <panleicim@gmail.com>
Date: Thu, 31 Mar 2022 18:12:57 +0200
Subject: [PATCH] add scheduler.py

---
 scheduler.py | 37 +++++++++++++++++++++++++++++++++++++
 1 file changed, 37 insertions(+)
 create mode 100644 scheduler.py

diff --git a/scheduler.py b/scheduler.py
new file mode 100644
index 0000000..a5f1e95
--- /dev/null
+++ b/scheduler.py
@@ -0,0 +1,37 @@
+import logging
+import sys
+from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
+
+from apscheduler.schedulers.blocking import BlockingScheduler
+
+from logs.AppLogging import init_logger
+from wait_for_sms import start_waiting_sms
+
+
+def waiting_for_sms_job():
+    start_waiting_sms()
+
+
+def start_waiting_sms_job(sched):
+    sched.add_job(waiting_for_sms_job, 'cron', day_of_week='mon-sat', hour='20',
+                  minute='30',
+                  misfire_grace_time=10,
+                  second='0', timezone='Europe/Paris', max_instances=1)
+
+
+def config_and_start_jobs():
+    executors = {
+        'default': ThreadPoolExecutor(30),
+        'processpool': ProcessPoolExecutor(12)
+    }
+    sched = BlockingScheduler(executors=executors)
+    start_waiting_sms_job(sched)
+    sched.print_jobs()
+    sched.start()
+
+
+if __name__ == '__main__':
+    init_logger()
+    logger = logging.getLogger()
+    logger.addHandler(logging.StreamHandler(stream=sys.stdout))
+    config_and_start_jobs()