Add sensors for job queue status and queue count

custom_components/moonraker/const.py

@@ -59,6 +59,7 @@ class METHODS(Enum):
     PRINTER_FIRMWARE_RESTART = "printer.firmware_restart"
     SERVER_FILES_METADATA = "server.files.metadata"
     SERVER_HISTORY_TOTALS = "server.history.totals"
+    SERVER_JOB_QUEUE_STATUS = "server.job_queue.status"
     SERVER_RESTART = "server.restart"
     SERVER_WEBCAMS_LIST = "server.webcams.list"
 

custom_components/moonraker/sensor.py

@@ -281,6 +281,7 @@ async def async_setup_entry(hass, entry, async_add_entities):
     await async_setup_optional_sensors(coordinator, entry, async_add_entities)
     await async_setup_history_sensors(coordinator, entry, async_add_entities)
     await async_setup_machine_update_sensors(coordinator, entry, async_add_entities)
+    await async_setup_queue_sensors(coordinator, entry, async_add_entities)
 
 
 async def async_setup_basic_sensor(coordinator, entry, async_add_entities):
@@ -585,6 +586,44 @@ async def async_setup_history_sensors(coordinator, entry, async_add_entities):
     await coordinator.async_refresh()
     async_add_entities([MoonrakerSensor(coordinator, entry, desc) for desc in sensors])
 
+async def _queue_updater(coordinator):
+    return {
+        "queue": await coordinator.async_fetch_data(METHODS.SERVER_JOB_QUEUE_STATUS)
+    }
+
+async def async_setup_queue_sensors(coordinator, entry, async_add_entities):
+    """Job queue sensors."""
+    queue = await coordinator.async_fetch_data(METHODS.SERVER_JOB_QUEUE_STATUS)
+    if queue.get("error"):
+        return
+
+    coordinator.add_data_updater(_queue_updater)
+
+    sensors = [
+        MoonrakerSensorDescription(
+            key="queue_state",
+            name="Queue State",
+            value_fn=lambda sensor: sensor.coordinator.data["queue"][
+                "queue_state"
+            ],
+            subscriptions=[("queue_state")],
+        ),
+        MoonrakerSensorDescription(
+            key="queue_count",
+            name="Jobs in queue",
+            value_fn=lambda sensor: len(sensor.coordinator.data["queue"][
+                "queued_jobs"
+            ]),
+            subscriptions=[("queued_jobs")],
+            icon="mdi:numeric",
+            unit="Jobs",
+            state_class=SensorStateClass.MEASUREMENT,
+        )
+    ]
+
+    coordinator.load_sensor_data(sensors)
+    await coordinator.async_refresh()
+    async_add_entities([MoonrakerSensor(coordinator, entry, desc) for desc in sensors])
 
 async def _machine_update_updater(coordinator):
     return {

docs/entities/sensors.rst

@@ -97,6 +97,12 @@ Sensors that are added on integration startup.
   * - Total Layer
     - Total number of layer in the current print.
     - From Moonraker API (print_stats, info, total_layer). Make sure your Slicer include it. `Details <https://github.com/marcolivierarsenault/moonraker-home-assistant/issues/112#issuecomment-1505664692>`__
+  * - Queue State
+    - State of the print job queue.
+    - From Moonraker API (ready, loading, starting, paused). `Details <https://moonraker.readthedocs.io/en/latest/web_api/#retrieve-the-job-queue-status>`__
+  * - Jobs in queue
+    - Number of print jobs in the job queue.
+    - From Moonraker API (queued_jobs)
 
 
 History Sensors