diff --git a/cephfs_disk_usage/server.py b/cephfs_disk_usage/server.py
index 82f2d0e..ecda0da 100644
--- a/cephfs_disk_usage/server.py
+++ b/cephfs_disk_usage/server.py
@@ -150,7 +150,7 @@ async def dir_entry(self, path: str) -> DirEntry:
 
         tasks = set()
         for child in fullpath.iterdir():
-            tasks.add(tg.create_task(self._get_meta(child)))
+            tasks.add(asyncio.create_task(self._get_meta(child)))
 
         ret = DirEntry.from_entry(await self._get_meta(fullpath))
         start_time = time.time()