|
@@ -22,7 +22,9 @@ from rq import Queue, Worker, Connection
|
|
|
from rq.registry import StartedJobRegistry, FinishedJobRegistry, DeferredJobRegistry, FailedJobRegistry, ScheduledJobRegistry, CanceledJobRegistry
|
|
|
from api.exception.command_exception import CommandException
|
|
|
from apscheduler.schedulers.background import BackgroundScheduler
|
|
|
-from apscheduler.triggers.interval import IntervalTrigger,CronTrigger
|
|
|
+from apscheduler.triggers.date import DateTrigger
|
|
|
+from apscheduler.triggers.cron import CronTrigger
|
|
|
+from apscheduler.triggers.interval import IntervalTrigger
|
|
|
|
|
|
# 指定 Redis 容器的主机名和端口
|
|
|
redis_conn = Redis(host='websoft9-redis', port=6379)
|