updated scheduler

This commit is contained in:
Marvin Zhang
2019-04-17 13:08:06 +08:00
parent 8bad2c49b1
commit 747dc470bb
2 changed files with 15 additions and 0 deletions

View File

@@ -2,6 +2,7 @@ import requests
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstores.mongodb import MongoDBJobStore
from pymongo import MongoClient
from flask import current_app
from config import MONGO_DB, MONGO_HOST, MONGO_PORT, FLASK_HOST, FLASK_PORT
from constants.spider import CronEnabled
@@ -29,8 +30,11 @@ class Scheduler(object):
def restart(self):
self.scheduler.shutdown()
self.scheduler.start()
current_app.logger.info('restarted')
def update(self):
current_app.logger.info('updating...')
# remove all existing periodic jobs
self.scheduler.remove_all_jobs()
@@ -50,6 +54,8 @@ class Scheduler(object):
day_of_week=day_of_week, month=month, day=day, hour=hour, minute=minute,
second=second)
current_app.logger.info('updated')
def run(self):
self.update()
self.scheduler.start()

View File

@@ -22,6 +22,15 @@ const actions = {
.then(response => {
commit('SET_SCHEDULE_LIST', response.data.items)
})
},
addSchedule ({ state }) {
request.put('/schedules', state.scheduleForm)
},
editSchedule ({ state }, id) {
request.post(`/schedules/${id}`, state.scheduleForm)
},
removeSchedule ({ state }, id) {
request.delete(`/schedules/${id}`)
}
}