🚧 fix(wip): move info

Prismadic · Jul 8, 2024 · 9efa097 · 9efa097
1 parent 07c9c1d
commit 9efa097
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/magnet/ic/field.py b/magnet/ic/field.py
@@ -272,9 +272,8 @@ async def listen(self, cb=print, job_n: int = None, generic: bool = False, v=Fal
                 loop.create_task(cb(self.object_store, e))
                 _f("info",
                    f'consuming objects from [{self.magnet.config.os_name}] on\n🛰️ stream: {self.magnet.config.stream_name}\n🧲 session: "{self.magnet.config.session}"')
-                await asyncio.sleep(3600)
-                _f("info",
-                    f'consuming delta from [{self.magnet.config.category}] on\n🛰️ stream: {self.magnet.config.stream_name}\n🧲 session: "{self.magnet.config.session}"')
+                await asyncio.sleep(1)
+
             else:
                 while True:
                     try:
@@ -294,6 +293,8 @@ async def listen(self, cb=print, job_n: int = None, generic: bool = False, v=Fal
                         else:
                             _f('fatal', str(e))
                     await asyncio.sleep(1)
+                    _f("info",
+                        f'consuming delta from [{self.magnet.config.category}] on\n🛰️ stream: {self.magnet.config.stream_name}\n🧲 session: "{self.magnet.config.session}"')
 
     async def worker(self, cb=print):
         """