feat: Avoid the controller waiting too long to be awaken

Konubinix · Oct 17, 2023 · 8bc43f5 · 8bc43f5
1 parent 84abdea
commit 8bc43f5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/ipfsworker.py b/ipfsworker.py
@@ -124,6 +124,8 @@ async def main():
         host=os.environ["REDIS_HOST"],
     )
     hostname = os.environ["WORKER_NAME"]
+    # simply tell the controller that it might be awaken to send some work
+    await client.publish("ipfsworker.controller.wake", "dummy")
     await asyncio.gather(
         add_files(client, hostname),
         inform_remaining_size(client, hostname),