Added unit test, lowered level of logs to debug, tweaked quit after f…

…ailing test

golem/task/requestedtaskmanager.py

@@ -359,20 +359,20 @@ async def abort_task(self, task_id):
         await self._shutdown_app_client(task.app_id)
 
     async def quit(self):
-        logger.info('quit()')
+        logger.debug('quit()')
         # Abort active tasks?
 
         # Shutdown registered app_clients
-        for app_id, app_client in self._app_clients:
+        for app_id, app_client in self._app_clients.items():
             logger.info('Shutting down app. app_id=%r', app_id)
             try:
                 await app_client.shutdown()
             except Exception:  # pylint: disable=broad-except
                 logger.warning("Failed to shutdown app. app_id=%r", app_id)
-            finally:
-                del self._app_clients[app_id]
 
-        logger.info('quit() - DONE')
+        self._app_clients.clear()
+
+        logger.debug('quit() - DONE')
 
     async def _get_app_client(
             self,

tests/golem/task/test_requestedtaskmanager.py

@@ -253,6 +253,19 @@ async def test_task_timeout(self, mock_client):
         await asyncio.sleep(task_timeout)
         assert self.rtm.is_task_finished(task_id)
 
+    @pytest.mark.asyncio
+    async def test_quit(self, mock_client):
+        # given
+        task_id = self._create_task()
+        await self.rtm.init_task(task_id)
+
+        # when
+        await self.rtm.quit()
+
+        # then
+        mock_client.shutdown.assert_called_once_with()
+        assert not self.rtm._app_clients
+
     def _build_golem_params(self, task_timeout=1) -> CreateTaskParams:
         return CreateTaskParams(
             app_id='a',