Close dummy samplers

This fixes some ResourceWarnings.
ska-sa · Apr 8, 2022 · 23e45c0 · 23e45c0
1 parent 784af0e
commit 23e45c0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/aiokatcp/server.py b/src/aiokatcp/server.py
@@ -871,9 +871,12 @@ async def request_sensor_sampling(
             # (so that the whole request is atomic).
             for s in sensors:
                 try:
-                    sensor.SensorSampler.factory(s, _dummy_observer, self.loop, strategy, *args)
+                    sampler = sensor.SensorSampler.factory(
+                        s, _dummy_observer, self.loop, strategy, *args)
                 except (TypeError, ValueError) as error:
                     raise FailReply(str(error)) from error
+                if sampler is not None:
+                    sampler.close()
             # Now create them for real
             for s in sensors:
                 try: