#scheduler 1
class Scheduler1(RQScheduler):
    def __init__(self, config: Config):
        self._config = config
        self._redis_connection = Redis(host=config.REDIS_HOST, port=config.REDIS_PORT)
        self._queue = Queue("QUEUE 1", connection=self._redis_connection)
        super().__init__(
            queue=self._queue,
            connection=self._redis_connection,
            interval=5,
        )

    def run(self):
        self.schedule(
                scheduled_time=datetime.now(timezone.utc),
                func=task_1,
                args=[...],
                interval=1800,
                repeat=None,
                timeout=900,
                id="***t",
                result_ttl=7 * 24 * 60 * 60,
            )
        ...

#scheduler 2
class Scheduler2(RQScheduler):
    def __init__(self, config: Config):
        self._config = config
        self._redis_connection = Redis(host=config.REDIS_HOST, port=config.REDIS_PORT)
        self._queue = Queue("QUEUE 2", connection=self._redis_connection)
        super().__init__(
            queue=self._queue,
            connection=self._redis_connection,
            interval=5,
        )

    def run(self):
        self.schedule(
                scheduled_time=datetime.now(timezone.utc),
                func=task_2,
                args=[...],
                interval=300,
                repeat=None,
                timeout=180,
                id="***t",
                result_ttl=7 * 24 * 60 * 60,
            )
        ...

#worker 1
if __name__ == "__main__":
    redis_connection = Redis(config.REDIS_HOST, config.REDIS_PORT)

    try:
        with Connection(connection=redis_connection):
            worker = Worker(["QUEUE 1"])
            worker.work()
    finally:
        redis_connection.close()

#worker 2
if __name__ == "__main__":
    redis_connection = Redis(config.REDIS_HOST, config.REDIS_PORT)

    try:
        with Connection(connection=redis_connection):
            worker = Worker(["QUEUE 2"])
            worker.work()
    finally:
        redis_connection.close()