(
self,
input: Union[str, Dict],
config: Optional[RunnableConfig] = None,
**kwargs: Any,
)
| 251 | return create_schema_from_function(self.name, self._run) |
| 252 | |
| 253 | def invoke( |
| 254 | self, |
| 255 | input: Union[str, Dict], |
| 256 | config: Optional[RunnableConfig] = None, |
| 257 | **kwargs: Any, |
| 258 | ) -> Any: |
| 259 | config = ensure_config(config) |
| 260 | return self.run( |
| 261 | input, |
| 262 | callbacks=config.get("callbacks"), |
| 263 | tags=config.get("tags"), |
| 264 | metadata=config.get("metadata"), |
| 265 | run_name=config.get("run_name"), |
| 266 | run_id=config.pop("run_id", None), |
| 267 | config=config, |
| 268 | **kwargs, |
| 269 | ) |
| 270 | |
| 271 | async def ainvoke( |
| 272 | self, |