code: def run(self, schedule_id, **kwargs):
          
          subscriptions = Subscription.objects.filter(
              schedule_id=schedule_id, active=True, completed=False, process_status=0
          ).values("id")
          for subscription in subscriptions.iterator():
              send_next_message.delay(str(subscription["id"]))
docs: Arguments:
              schedule_id {int} -- The schedule to send messages for