m-scheduler-partitioning 0.1.3

Mobio scheduler partitioning sdk

Thư viện scheduler multiple partitions của Profiling

nop: maximum partitions now support is 1000
delays: maximum time delays now support is 3600 seconds (1 hour)

sample code:

from mobio.libs.m_scheduler_partitioning.m_scheduler import MobioScheduler
from mobio.libs.m_scheduler_partitioning.scheduler_models.scheduler_state_model import SchedulerStateModel


class SampleScheduler(MobioScheduler):
    def process(self):
        if self.url_connection:
            SchedulerStateModel(self.url_connection).set_busy(
                worker_id=self.node_id
            )
        print("Hi there ! :)")


if __name__ == "__main__":
    SampleScheduler(root_node="test-scheduler", nop=100, delays=1)

Change logs

• 0.1.2

  1. log state of worker
  2. get free worker
  3. Để không bị mất 50k cho anh Lợi, thêm 2 index này:

  * db.scheduler_state.createIndex({"expiry_time": 1}, {expireAfterSeconds: 5, name="expiry_time_1"})
  * db.scheduler_state.createIndex({"root_node": 1, "state":1}, {name="root_node_1_state_1"})
  

• 0.1.3

  1. fix issue rebalance not update list partition to db