Update

.github/workflows/_test_langgraph.yml

@@ -25,12 +25,13 @@ jobs:
           - python-version: "3.11"
             core-version: ">=0.2.42,<0.3.0"
           - python-version: "3.11"
+            core-version: "latest"
             ff-send-v2: "true"
 
     defaults:
       run:
         working-directory: libs/langgraph
-    name: "test #${{ matrix.python-version }} (langchain-core: ${{ matrix.core-version }})"
+    name: "test #${{ matrix.python-version }} (langchain-core: ${{ matrix.core-version }}, ff-send-v2: ${{ matrix.ff-send-v2 }})"
     steps:
       - uses: actions/checkout@v4
       - name: Set up Python ${{ matrix.python-version }} + Poetry ${{ env.POETRY_VERSION }}

libs/scheduler-kafka/tests/test_push.py

@@ -9,7 +9,7 @@ import pytest
 from aiokafka import AIOKafkaProducer
 
 from langgraph.checkpoint.base import BaseCheckpointSaver
-from langgraph.constants import START
+from langgraph.constants import FF_SEND_V2, START
 from langgraph.errors import NodeInterrupt
 from langgraph.graph.state import CompiledStateGraph, GraphCommand, StateGraph
 from langgraph.scheduler.kafka import serde
@@ -77,6 +77,9 @@ def mk_push_graph(
 
 
 async def test_push_graph(topics: Topics, acheckpointer: BaseCheckpointSaver) -> None:
+    if not FF_SEND_V2:
+        pytest.skip("Test requires FF_SEND_V2")
+
     input = ["0"]
     config = {"configurable": {"thread_id": "1"}}
     graph = mk_push_graph(acheckpointer)

libs/scheduler-kafka/tests/test_push_sync.py

@@ -8,7 +8,7 @@ from typing import (
 import pytest
 
 from langgraph.checkpoint.base import BaseCheckpointSaver
-from langgraph.constants import START
+from langgraph.constants import FF_SEND_V2, START
 from langgraph.errors import NodeInterrupt
 from langgraph.graph.state import CompiledStateGraph, GraphCommand, StateGraph
 from langgraph.scheduler.kafka import serde
@@ -77,6 +77,9 @@ def mk_push_graph(
 
 
 def test_push_graph(topics: Topics, acheckpointer: BaseCheckpointSaver) -> None:
+    if not FF_SEND_V2:
+        pytest.skip("Test requires FF_SEND_V2")
+
     input = ["0"]
     config = {"configurable": {"thread_id": "1"}}
     graph = mk_push_graph(acheckpointer)