Error with async redis checkpointer

[abigailrb03]

I'm trying to use AsyncRedisSaver in my project to implement short term memory. I previously implemented InMemoryStore successfully as a checkpointer, however I wanted to switch to Redis. I'm using the async implementation as I have a fairly large graph that has several async calls. I went through my code to see if anything is missing an async call (the coroutine error seems to suggest that I'm missing an await or async but haven't found anything). It's very similar to the issue discussed here but with redis.

The relevant portion of my setup is below:
class Db2IcWorkflow(BaseAgent):

def __init__(self):
    super().__init__()
        self._workflow              = None
        self._checkpointer              = None

    @property
      async def workflow(self):
          if self._workflow is None:
              self._workflow = self.builder.compile(checkpointer=self.checkpointer)
          return self._workflow

      @property
      async def checkpointer(self):
          if self._checkpointer is None:
              REDIS_URI = "redis://localhost:6379"
              async with AsyncRedisSaver.from_conn_string("redis://localhost:6379") as checkpointer:
                  await checkpointer.asetup()
                  self._checkpointer = checkpointer
          return self._checkpointer

    async def run(self, config: RunnableConfig):
          async for event in self.workflow.astream_events(inputs, version="v2", config=config, subgraphs=True):
                # EXECUTE WORKFLOW

Stack trace:

Exception 'coroutine' object has no attribute 'get_next_version'
Traceback (most recent call last):
File ".venv/lib/python3.11/site-packages/project/workflows/workflows.py", line 285, in run
async for event in self.workflow.astream_events(inputs, version="v2", config=config, subgraphs=True):
File ".venv/lib/python3.11/site-packages/langchain_core/runnables/base.py", line 1404, in astream_events
async for event in event_stream:
File "venv/lib/python3.11/site-packages/langchain_core/tracers/event_stream.py", line 1021, in _astream_events_implementation_v2
await task
File ".venv/lib/python3.11/site-packages/langchain_core/tracers/event_stream.py", line 976, in consume_astream
async for _ in event_streamer.tap_output_aiter(run_id, stream):
File ".venv/lib/python3.11/site-packages/langchain_core/tracers/event_stream.py", line 181, in tap_output_aiter
first = await py_anext(output, default=sentinel)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File ".venv/lib/python3.11/site-packages/langchain_core/utils/aiter.py", line 78, in anext_impl
return await anext(iterator)
^^^^^^^^^^^^^^^^^^^^^^^^^
File ".venv/lib/python3.11/site-packages/langgraph/pregel/init.py", line 2704, in astream
async with AsyncPregelLoop(
^^^^^^^^^^^^^^^^
File ".venv/lib/python3.11/site-packages/langgraph/pregel/loop.py", line 1151, in init
self.checkpointer_get_next_version = checkpointer.get_next_version
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
AttributeError: 'coroutine' object has no attribute 'get_next_version'