lock issues related to redis

[jamesalphanome]

lock issues related to redis

I am facing lock issues when running my reflex app, connected to redis, the locks are occuring when I am connecting to a public redis (redis://:yourpassword@<public_ip>:6379), but this is not happening when connecting with a redis on localhost (redis://localhost:6379)

To Reproduce

class A(rx.State, mixin=True):
    """mixin"""

    @rx.event(background=True)
    async def on_success(self):
        raise NotImplementedError("Implement this eventhandler - mixin")

    @rx.event(background=True)
    async def process(self):
        await asyncio.sleep(1)

        yield self.__class__.on_success


class B(A, rx.State):
    """The app state."""

    file_uploading: bool = False

    @rx.event
    async def set_state(self):
        await asyncio.sleep(0.6) # small operation

    @rx.event
    async def completed_toast(self):
        return rx.toast.success("Done.")

    @rx.event(background=True)
    async def on_success(self):
        yield B.completed_toast


def index() -> rx.Component:
    return rx.container(
        rx.color_mode.button(position="top-right"),
        rx.button(
            "Click me",
            on_click=B.process,
        ),
    )


app = rx.App()
app.add_page(index, on_load=B.set_state)

I have a simple repo: repo_link

Expected behavior
No locks, I am not sure what is happening, am I missing something ?

Screenshots

• Python Version: 3.13
• Reflex Version: 0.8.21
• OS: macos
• Browser (Optional): Chrome

I have a production set up (Azure container apps) that is connected to a single Azure managed redis in a vpn, and I am getting the above lock issues there. It is a bit of a problem. I am getting this issue in reflex 0.7.14 and above. 0.7.13 is working fine.
But even testing with the repo I have shared above, i am getting lock issues when connecting to a public redis with reflex versions as low as 0.6.8 (haven't tested further).

[masenf]

is it possible that the latency on the public redis instance is high enough that it's exceeding the lock warning threshold? are you actually getting LockExpiredError? or just the warnings?

[jamesalphanome]

is it possible that the latency on the public redis instance is high enough that it's exceeding the lock warning threshold? are you actually getting LockExpiredError? or just the warnings?

i am getting only the warnings, even for a newly initialised reflex app with the starter template.

"""Welcome to Reflex! This file outlines the steps to create a basic app."""

import reflex as rx

from rxconfig import config


class State(rx.State):
    """The app state."""


def index() -> rx.Component:
    # Welcome Page (Index)
    return rx.container(
        rx.color_mode.button(position="top-right"),
        rx.vstack(
            rx.heading("Welcome to Reflex!", size="9"),
            rx.text(
                "Get started by editing ",
                rx.code(f"{config.app_name}/{config.app_name}.py"),
                size="5",
            ),
            rx.link(
                rx.button("Check out our docs!"),
                href="https://reflex.dev/docs/getting-started/introduction/",
                is_external=True,
            ),
            spacing="5",
            justify="center",
            min_height="85vh",
        ),
    )


app = rx.App()
app.add_page(index)

-------------------------------

import reflex as rx

config = rx.Config(
    app_name="new_try_2",
    plugins=[
        rx.plugins.SitemapPlugin(),
        rx.plugins.TailwindV4Plugin(),
    ],
    redis_url="redis://:yourpassword@<ip>:6379",
)

is this expected behaviour ?

[tzktok]

any update on this @masenf