code: def schedule_window(report_type, start_at, stop_at, resolution):
      
      model_cls = get_scheduler_model(report_type)
      dbsession = db.create_scoped_session()
      schedules = dbsession.query(model_cls).filter(model_cls.active.is_(True))
  
      for schedule in schedules:
          args = (
              report_type,
              schedule.id,
          )
  
          # Schedule the job for the specified time window
          for eta in next_schedules(schedule.crontab,
                                    start_at,
                                    stop_at,
                                    resolution=resolution):
              schedule_email_report.apply_async(args, eta=eta)
docs: Find all active schedules and schedule celery tasks for
      each of them with a specific ETA (determined by parsing
      the cron schedule for the schedule)