Skip to content

Commit f3685e0

Browse files
authored
update scheduler job
1 parent a3e6a35 commit f3685e0

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/wechaty/plugin.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import inspect
2626
from logging import Logger
2727
import os
28+
from ssl import SSLEOFError
2829
import sys
2930
import re
3031
from abc import ABC
@@ -248,10 +249,14 @@ def add_daily_job(
248249
trigger = CronTrigger(
249250
hour=hour
250251
)
252+
job = self.scheduler.get_job(job_id=job_id)
253+
if job is not None:
254+
self.scheduler.remove_job(job_id=job_id)
251255

252256
self.scheduler.add_job(
253257
func=handler,
254258
trigger=trigger,
259+
id=job_id,
255260
args=args,
256261
kwargs=kwargs
257262
)

0 commit comments

Comments
 (0)