this repo has no description
cal-bridge: fix mqtt bits
+9
-8
+4
-4
cal-bridge/src/cal_bridge/cal_mqtt.py
+4
-4
cal-bridge/src/cal_bridge/cal_mqtt.py
···
1
-
import cal_bridge.schedule
2
1
import cal_bridge.mqtt as mqtt_conn
3
2
import cal_bridge.calendar as calendar
4
3
from cal_bridge.conf import topics
···
50
49
last_start_published = datetime.now(tz=timezone.utc)
51
50
52
51
53
-
cal_bridge.schedule.scheduler.add_job(
54
-
check, CronTrigger(minute=0), next_run_time=datetime.now()
55
-
) # every hour
52
+
def add_to_schedule(schedule):
53
+
schedule.add_job(
54
+
check, CronTrigger(minute=0), next_run_time=datetime.now()
55
+
) # every hour
+3
cal-bridge/src/cal_bridge/main.py
+3
cal-bridge/src/cal_bridge/main.py
···
8
8
import cal_bridge.calendar
9
9
import cal_bridge.todos
10
10
from cal_bridge.schedule import scheduler
11
+
from cal_bridge import cal_mqtt, todos_mqtt # pyright: ignore
11
12
12
13
logger = logging.getLogger()
13
14
···
22
23
@asynccontextmanager
23
24
async def lifespan(_: FastAPI):
24
25
logger.debug("starting up...")
26
+
cal_mqtt.add_to_schedule(scheduler)
27
+
todos_mqtt.add_to_schedule(scheduler)
25
28
scheduler.start()
26
29
mqtt_conn.get()
27
30
yield
+2
-4
cal-bridge/src/cal_bridge/todos_mqtt.py
+2
-4
cal-bridge/src/cal_bridge/todos_mqtt.py
···
1
-
import cal_bridge.schedule
2
1
import cal_bridge.mqtt as mqtt_conn
3
2
from cal_bridge.todos import Todos, Todo, get_todos
4
3
from cal_bridge.conf import topics
···
73
72
prev_todos = todos
74
73
75
74
76
-
cal_bridge.schedule.scheduler.add_job(
77
-
check, IntervalTrigger(hours=1), next_run_time=datetime.now()
78
-
)
75
+
def add_to_schedule(schedule):
76
+
schedule.add_job(check, IntervalTrigger(hours=1), next_run_time=datetime.now())