rebalance actually rebalances

dcron/site.py

@@ -26,6 +26,8 @@
 import json
 import logging
 import pathlib
+import time
+from datetime import datetime
 
 import jinja2
 
@@ -35,7 +37,7 @@
 
 from dcron.cron.cronitem import CronItem
 from dcron.datagram.client import broadcast
-from dcron.protocols.messages import Kill, Run, Toggle
+from dcron.protocols.messages import Kill, Run, Toggle, ReBalance
 from dcron.protocols.udpserializer import UdpSerializer
 from dcron.storage import CronEncoder
 from dcron.utils import get_ip
@@ -134,6 +136,14 @@ async def re_balance(self, request):
 
         self.scheduler.re_balance()
 
+        jobs = self.storage.cluster_jobs.copy()
+
+        broadcast(self.udp_port, UdpSerializer.dump(ReBalance(timestamp=datetime.now()), self.hash_key))
+
+        time.sleep(5)
+        for job in jobs:
+            broadcast(self.udp_port, UdpSerializer.dump(job, self.hash_key))
+
         raise web.HTTPAccepted()
 
     async def kill_job(self, request):

setup.cfg

@@ -1,5 +1,5 @@
 [bumpversion]
-current_version = 0.9.17
+current_version = 0.9.18
 commit = True
 tag = True
 

setup.py

@@ -29,7 +29,7 @@
 
 from setuptools import setup
 
-version = "0.9.17"
+version = "0.9.18"
 
 requirements = ['aiohttp',
                 'aiofiles',