diff --git a/confluent_server/confluent/plugins/hardwaremanagement/pdu.py b/confluent_server/confluent/plugins/hardwaremanagement/pdu.py
index d3c0f049..1da24daa 100644
--- a/confluent_server/confluent/plugins/hardwaremanagement/pdu.py
+++ b/confluent_server/confluent/plugins/hardwaremanagement/pdu.py
@@ -55,8 +55,8 @@ def retrieve(nodes, element, configmanager, inputdata):
         while gp.running():
             try:
                 nrsp = rspq.get(timeout=0.1)
-            if nrsp is not None and not isinstance(nrsp, TaskDone):
-                yield nrsp
+                if nrsp is not None and not isinstance(nrsp, TaskDone):
+                    yield nrsp
             except queue.Empty:
                 continue
         while not rspq.empty():