diff --git a/crawlab/tasks/scheduler.py b/crawlab/tasks/scheduler.py index d4249bf7..da6303c9 100644 --- a/crawlab/tasks/scheduler.py +++ b/crawlab/tasks/scheduler.py @@ -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() diff --git a/frontend/src/store/modules/schedule.js b/frontend/src/store/modules/schedule.js index 04174f3a..3c322133 100644 --- a/frontend/src/store/modules/schedule.js +++ b/frontend/src/store/modules/schedule.js @@ -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}`) } }