dash_scheduler.py

import schedule
import time
import logging

from datetime import datetime


class DashScheduler:
    def __init__(self, dashes, render_function, context, seconds_in_advance, full_clear_interval):
        self.dashes = dashes
        self.render_function = render_function
        self.context = context
        self.seconds_in_advance = seconds_in_advance
        self.current_refresh = 1
        self.full_clear_interval = full_clear_interval

    def run(self):
        logging.info("Running all dashes.")

        for dash in self.dashes:
            dash.draw_content()

        # (render_context, current_refresh, clear_interval):
        self.current_refresh = self.current_refresh + 1
        if self.current_refresh > self.full_clear_interval:
            self.current_refresh = 0

        # If time is within refreshing hours, skip refresh
        current_hour = datetime.now().hour
        if 9 <= current_hour < 21:
            self.render_function(self.context, self.current_refresh, self.full_clear_interval)
            logging.info("Cycle completed.")
        else:
            logging.info("Outside of refreshing hours, skipping.")

    def start(self):
        logging.info("Scheduling job started.")
        self.run()
        scheduled_seconds_in_minute = 60 - self.seconds_in_advance
        formatted_scheduled_seconds_in_minute = ":00" if scheduled_seconds_in_minute == 60 \
                                                else ":{}".format(scheduled_seconds_in_minute)

        schedule.every().minute.at(formatted_scheduled_seconds_in_minute).do(self.run)

        while True:
            schedule.run_pending()
            time.sleep(5)