Spark: Schedule.every (10) .minutes.do (main) .run () иногда не запускался - PullRequest
0 голосов
/ 04 апреля 2019

У меня есть программа зажигания, которая должна запускаться каждые 10 минут. Из моего журнала время от времени задание пропускается примерно через 20 минут, а затем снова запускается через 30 минут после последнего запуска.

Ожидаемое: запускать каждые 10 минут. Фактически: иногда работа не выполняется.

В настоящее время я не могу найти решение от stackoverflow, но я нашел run_continuously () из https://github.com/mrhwick/schedule/blob/master/schedule/init.py

Мой код как ниже: if name == " main ":

schedule.every(10).minutes.do(main).run()

while 1:
    schedule.run_pending()
    time.sleep(1)

Вопрос: что приведет к тому, что run_pending () не будет работать? Если я использую run_continuously, я просто заменяю run_pending () на run_continuously (10)?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...