|
|
@@ -390,7 +390,7 @@ async def _dbus_signal_loop_unit( # pylint: disable=too-many-arguments
|
|
|
unit_name=unit_name
|
|
|
)
|
|
|
((_, last_active_state),) = await unit_proxy.Get(property_name="ActiveState")
|
|
|
- await mqtt_client.publish(topic=active_state_topic, payload=last_active_state)
|
|
|
+ await mqtt_client.publish(topic=active_state_topic, payload=last_active_state, retain=True)
|
|
|
with dbus_router.filter(unit_properties_changed_match_rule) as queue:
|
|
|
while True:
|
|
|
await queue.get()
|