the reason I have sleep(self.scheduler_interval + self.scheduler_interval / 2) is cause the total number of policies to be picked by the scheduler are over the batch size and I am giving it upto half the time before the scheduler rerun for these to be triggered.