mirror of
https://github.com/langgenius/dify.git
synced 2026-08-25 11:59:42 -04:00
林玮 (Jade Lin)
45 lines
1.4 KiB
Python
45 lines
1.4 KiB
Python
from collections.abc import Callable, Generator, Sequence
|
|
from typing import Any, override
|
|
|
|
from graphon.model_runtime.entities.llm_entities import LLMStructuredOutput
|
|
from graphon.model_runtime.entities.message_entities import PromptMessage
|
|
from graphon.node_events.base import NodeEventBase
|
|
from graphon.nodes.llm.node import LLMNode
|
|
from graphon.nodes.llm.runtime_protocols import LLMPollingCapableProtocol
|
|
|
|
|
|
# TODO: Remove this Dify-specific node once graphon exposes a polling finalization hook.
|
|
class DifyLLMNode(LLMNode):
|
|
"""Dify-owned LLM node lifecycle extensions."""
|
|
|
|
@classmethod
|
|
@override
|
|
def version(cls) -> str:
|
|
return "1"
|
|
|
|
def __init__(
|
|
self,
|
|
*args: Any,
|
|
polling_finalizer: Callable[[], None],
|
|
**kwargs: Any,
|
|
) -> None:
|
|
super().__init__(*args, **kwargs)
|
|
self._polling_finalizer = polling_finalizer
|
|
|
|
@override
|
|
def _invoke_llm_with_polling(
|
|
self,
|
|
*,
|
|
polling_model: LLMPollingCapableProtocol,
|
|
prompt_messages: Sequence[PromptMessage],
|
|
stop: Sequence[str] | None,
|
|
) -> Generator[NodeEventBase | LLMStructuredOutput, None, None]:
|
|
try:
|
|
yield from super()._invoke_llm_with_polling(
|
|
polling_model=polling_model,
|
|
prompt_messages=prompt_messages,
|
|
stop=stop,
|
|
)
|
|
finally:
|
|
self._polling_finalizer()
|