remote: reduce debug output

Signed-off-by: Jan Luebbe <[email protected]>

labgrid/remote/common.py

@@ -469,12 +469,11 @@ async def queue_as_aiter(q):
     try:
         while True:
             item = await q.get()
-            logging.info(f"queue_as_aiter item {item}")
             if item is None:
                 return
             yield item
             q.task_done()
-            print(f"sent {item}")
+            logging.debug(f"sent message {item}")
     except Exception:
         logging.exception("error in queue_as_aiter")
         raise

labgrid/remote/coordinator.py

@@ -662,7 +662,6 @@ async def request_task():
                     await self._update_acquired_places(action, resource, callback=False)
 
             logging.debug(f"exporter aborted {context.peer()}, cancelled: {context.cancelled()}")
-            logging.debug("Exporters: %s", self.exporters)
 
     async def AcquirePlace(self, request, context):
         peer = context.peer()

labgrid/remote/exporter.py

@@ -801,7 +801,7 @@ async def message_pump(self):
         try:
             async for out_message in self.stub.ExporterStream(queue_as_aiter(self.out_queue)):
                 got_message = True
-                logging.debug(f"out_message {out_message}")
+                logging.debug(f"received message {out_message}")
                 kind = out_message.WhichOneof("kind")
                 if kind == "hello":
                     logging.info("connected to exporter version %s", out_message.hello.version)
@@ -929,15 +929,12 @@ async def add_resource(self, group_name, resource_name, cls, params):
     async def update_resource(self, group_name, resource_name):
         """Update status on the coordinator"""
         resource = self.groups[group_name][resource_name]
-        print(resource)
-        data = resource.asdict()
-        print(data)
         msg = labgrid_coordinator_pb2.ExporterInMessage()
         msg.resource.CopyFrom(resource.as_pb2())
         msg.resource.path.group_name = group_name
         msg.resource.path.resource_name = resource_name
-        print(f"encoded {msg}")
         self.out_queue.put_nowait(msg)
+        logging.info("queued update for resource %s/%s", group_name, resource_name)
 
 
 async def amain(config) -> bool: