Function github_task_monitor

app/tasks/github.py:311–320

(task_id, keyword, scheduler_id)

# Github 监控任务
def github_task_monitor(task_id, keyword, scheduler_id):
    task = GithubTaskMonitor(task_id=task_id,
                             keyword=keyword, scheduler_id=scheduler_id)
    try:
        task.run()
    except Exception as e:
        logger.exception(e)

        task.update_status(TaskStatus.ERROR)
        task.set_end_time()