|
3 | 3 | from .default_mcp_gym_rollout_processor import MCPGymRolloutProcessor |
4 | 4 | from .default_no_op_rollout_processor import NoOpRolloutProcessor |
5 | 5 | from .default_single_turn_rollout_process import SingleTurnRolloutProcessor |
6 | | -from .default_langchain_rollout_processor import LangGraphRolloutProcessor |
7 | 6 | from .evaluation_test import evaluation_test |
8 | 7 | from .exception_config import ExceptionHandlerConfig, BackoffConfig, get_default_exception_handler_config |
9 | 8 | from .rollout_processor import RolloutProcessor |
|
18 | 17 | PYDANTIC_AI_AVAILABLE = False |
19 | 18 | PydanticAgentRolloutProcessor = None |
20 | 19 |
|
| 20 | +# Conditional import for optional LangChain dependency |
| 21 | +try: |
| 22 | + from .default_langchain_rollout_processor import LangGraphRolloutProcessor |
| 23 | + |
| 24 | + LANGCHAIN_AVAILABLE = True |
| 25 | +except ImportError: |
| 26 | + LANGCHAIN_AVAILABLE = False |
| 27 | + LangGraphRolloutProcessor = None |
| 28 | + |
21 | 29 | __all__ = [ |
22 | 30 | "AgentRolloutProcessor", |
23 | 31 | "MCPGymRolloutProcessor", |
24 | 32 | "RolloutProcessor", |
25 | 33 | "SingleTurnRolloutProcessor", |
26 | | - "LangGraphRolloutProcessor", |
27 | 34 | "NoOpRolloutProcessor", |
28 | 35 | "default_dataset_adapter", |
29 | 36 | "RolloutProcessorConfig", |
|
36 | 43 | # Only add to __all__ if available |
37 | 44 | if PYDANTIC_AI_AVAILABLE: |
38 | 45 | __all__.append("PydanticAgentRolloutProcessor") |
| 46 | + |
| 47 | +if LANGCHAIN_AVAILABLE: |
| 48 | + __all__.append("LangGraphRolloutProcessor") |
0 commit comments