Update all samples to match SDK PR #1448 API

- graphs parameter is now a list, not a dict
- No graph()/entrypoint() lookup functions — reference objects directly
- No entrypoints parameter on LangGraphPlugin
- Use set_cache()/get_cache() for continue-as-new caching
- Update tests and READMEs accordingly

Author: DABH

langgraph_plugin/functional_api/continue_as_new/run_worker.py

@@ -11,14 +11,12 @@
     PipelineFunctionalWorkflow,
     activity_options,
     all_tasks,
-    pipeline_entrypoint,
 )
 
 
 async def main() -> None:
     client = await Client.connect(os.environ.get("TEMPORAL_ADDRESS", "localhost:7233"))
     plugin = LangGraphPlugin(
-        entrypoints={"pipeline": pipeline_entrypoint},
         tasks=all_tasks,
         activity_options=activity_options,
     )

langgraph_plugin/functional_api/continue_as_new/workflow.py

@@ -10,7 +10,7 @@
 from langgraph.func import entrypoint as lg_entrypoint
 from langgraph.func import task
 from temporalio import workflow
-from temporalio.contrib.langgraph import entrypoint, get_cache
+from temporalio.contrib.langgraph import get_cache, set_cache
 
 
 @task
@@ -65,9 +65,8 @@ class PipelineFunctionalWorkflow:
 
     @workflow.run
     async def run(self, input_data: PipelineInput) -> dict[str, Any]:
-        result = await entrypoint("pipeline", cache=input_data.cache).ainvoke(
-            input_data.data
-        )
+        set_cache(input_data.cache)
+        result = await pipeline_entrypoint.ainvoke(input_data.data)
 
         if input_data.phase < 3:
             workflow.continue_as_new(

langgraph_plugin/functional_api/control_flow/run_worker.py

@@ -11,14 +11,12 @@
     ControlFlowWorkflow,
     activity_options,
     all_tasks,
-    control_flow_pipeline,
 )
 
 
 async def main() -> None:
     client = await Client.connect(os.environ.get("TEMPORAL_ADDRESS", "localhost:7233"))
     plugin = LangGraphPlugin(
-        entrypoints={"control_flow": control_flow_pipeline},
         tasks=all_tasks,
         activity_options=activity_options,
     )

langgraph_plugin/functional_api/control_flow/workflow.py

@@ -11,7 +11,6 @@
 from langgraph.func import entrypoint as lg_entrypoint
 from langgraph.func import task
 from temporalio import workflow
-from temporalio.contrib.langgraph import entrypoint
 
 
 @task
@@ -93,4 +92,4 @@ async def control_flow_pipeline(items: list[str]) -> dict:
 class ControlFlowWorkflow:
     @workflow.run
     async def run(self, items: list[str]) -> dict:
-        return await entrypoint("control_flow").ainvoke(items)
+        return await control_flow_pipeline.ainvoke(items)

langgraph_plugin/functional_api/hello_world/run_worker.py

@@ -11,14 +11,12 @@
     HelloWorldFunctionalWorkflow,
     activity_options,
     all_tasks,
-    hello_entrypoint,
 )
 
 
 async def main() -> None:
     client = await Client.connect(os.environ.get("TEMPORAL_ADDRESS", "localhost:7233"))
     plugin = LangGraphPlugin(
-        entrypoints={"hello-world": hello_entrypoint},
         tasks=all_tasks,
         activity_options=activity_options,
     )

langgraph_plugin/functional_api/hello_world/workflow.py

@@ -8,7 +8,6 @@
 from langgraph.func import entrypoint as lg_entrypoint
 from langgraph.func import task
 from temporalio import workflow
-from temporalio.contrib.langgraph import entrypoint
 
 
 @task
@@ -36,4 +35,4 @@ async def hello_entrypoint(query: str) -> dict:
 class HelloWorldFunctionalWorkflow:
     @workflow.run
     async def run(self, query: str) -> dict:
-        return await entrypoint("hello-world").ainvoke(query)
+        return await hello_entrypoint.ainvoke(query)

langgraph_plugin/functional_api/human_in_the_loop/run_worker.py

@@ -11,14 +11,12 @@
     ChatbotFunctionalWorkflow,
     activity_options,
     all_tasks,
-    chatbot_entrypoint,
 )
 
 
 async def main() -> None:
     client = await Client.connect(os.environ.get("TEMPORAL_ADDRESS", "localhost:7233"))
     plugin = LangGraphPlugin(
-        entrypoints={"chatbot": chatbot_entrypoint},
         tasks=all_tasks,
         activity_options=activity_options,
     )

langgraph_plugin/functional_api/human_in_the_loop/workflow.py

@@ -12,7 +12,6 @@
 from langgraph.func import task
 from langgraph.types import Command, interrupt
 from temporalio import workflow
-from temporalio.contrib.langgraph import entrypoint
 
 
 @task
@@ -67,22 +66,21 @@ def get_draft(self) -> str | None:
 
     @workflow.run
     async def run(self, user_message: str) -> dict[str, Any]:
-        app = entrypoint("chatbot")
-        app.checkpointer = InMemorySaver()
+        chatbot_entrypoint.checkpointer = InMemorySaver()
         config = RunnableConfig(
             {"configurable": {"thread_id": workflow.info().workflow_id}}
         )
 
         # First invocation: runs until interrupt() pauses for human review
-        result = await app.ainvoke(user_message, config, version="v2")
+        result = await chatbot_entrypoint.ainvoke(user_message, config, version="v2")
 
         self._draft = result.interrupts[0].value
 
         # Wait for human feedback via Temporal signal
         await workflow.wait_condition(lambda: self._human_input is not None)
 
         # Resume with the human's feedback
-        resumed = await app.ainvoke(
+        resumed = await chatbot_entrypoint.ainvoke(
             Command(resume=self._human_input), config, version="v2"
         )
         return resumed.value

langgraph_plugin/functional_api/langsmith_tracing/run_worker.py

@@ -15,7 +15,6 @@
     ChatFunctionalWorkflow,
     activity_options,
     all_tasks,
-    chat_entrypoint,
 )
 
 
@@ -31,7 +30,6 @@ async def main() -> None:
         workflows=[ChatFunctionalWorkflow],
         plugins=[
             LangGraphPlugin(
-                entrypoints={"chat": chat_entrypoint},
                 tasks=all_tasks,
                 activity_options=activity_options,
             )

langgraph_plugin/functional_api/langsmith_tracing/workflow.py

@@ -13,7 +13,6 @@
 from langgraph.func import task
 from langsmith import traceable
 from temporalio import workflow
-from temporalio.contrib.langgraph import entrypoint
 
 from langchain.chat_models import init_chat_model
 
@@ -45,4 +44,4 @@ async def chat_entrypoint(message: str) -> dict:
 class ChatFunctionalWorkflow:
     @workflow.run
     async def run(self, message: str) -> dict:
-        return await entrypoint("chat").ainvoke(message)
+        return await chat_entrypoint.ainvoke(message)