Start a trace for a chain run.
(
self,
serialized: Dict[str, Any],
inputs: Dict[str, Any],
*,
run_id: UUID,
tags: Optional[List[str]] = None,
parent_run_id: Optional[UUID] = None,
metadata: Optional[Dict[str, Any]] = None,
run_type: Optional[str] = None,
name: Optional[str] = None,
**kwargs: Any,
)
| 170 | return llm_run |
| 171 | |
| 172 | def on_chain_start( |
| 173 | self, |
| 174 | serialized: Dict[str, Any], |
| 175 | inputs: Dict[str, Any], |
| 176 | *, |
| 177 | run_id: UUID, |
| 178 | tags: Optional[List[str]] = None, |
| 179 | parent_run_id: Optional[UUID] = None, |
| 180 | metadata: Optional[Dict[str, Any]] = None, |
| 181 | run_type: Optional[str] = None, |
| 182 | name: Optional[str] = None, |
| 183 | **kwargs: Any, |
| 184 | ) -> Run: |
| 185 | """Start a trace for a chain run.""" |
| 186 | chain_run = self._create_chain_run( |
| 187 | serialized=serialized, |
| 188 | inputs=inputs, |
| 189 | run_id=run_id, |
| 190 | tags=tags, |
| 191 | parent_run_id=parent_run_id, |
| 192 | metadata=metadata, |
| 193 | run_type=run_type, |
| 194 | name=name, |
| 195 | **kwargs, |
| 196 | ) |
| 197 | self._start_trace(chain_run) |
| 198 | self._on_chain_start(chain_run) |
| 199 | return chain_run |
| 200 | |
| 201 | def on_chain_end( |
| 202 | self, |
no test coverage detected