Added some missing logs

golem/task/requestedtaskmanager.py

@@ -534,6 +534,7 @@ async def _verify(
                     self._move_task_results(
                         task_id,
                         Path(task.output_directory))
+                    logger.info("Task finished. task_id=%r", task.task_id)
                     await self._shutdown_app_client(task.app_id)
                     self._notice_task_updated(task, op=TaskOp.FINISHED)
 

golem/task/taskrequestorstats.py

@@ -409,8 +409,11 @@ def on_message(self,
         elif op == TaskOp.WORK_OFFER_RECEIVED:
             self.tasks[task_id].got_want_to_compute()
             if task_state.status.is_active():
-                logger.info('Received work offers: %r',
-                            self.tasks[task_id].want_to_compute_count())
+                logger.info(
+                    'Received work offers. offer_count=%r, task_id=%r',
+                    self.tasks[task_id].want_to_compute_count(),
+                    task_id
+                )
 
         elif op == TaskOp.RESTORED:
             if task_state.status.is_completed():

golem/task/tasksession.py

@@ -253,9 +253,12 @@ def send_hello(self):
 
     def read_msg_queue(self):
         if not self.key_id:
+            logger.debug('skipping queue, no key_id')
             return
         if not self.verified:
+            logger.debug('skipping queue, not verified. key_id=%r', self.key_id)
             return
+        logger.debug('sending messages for key. %r', self.key_id)
         for msg in msg_queue.get(self.key_id):
             self.send(msg)