(
self,
*,
ctx: Context,
node_input: Any,
)
| 68 | |
| 69 | @override |
| 70 | async def run( |
| 71 | self, |
| 72 | *, |
| 73 | ctx: Context, |
| 74 | node_input: Any, |
| 75 | ) -> AsyncGenerator[Any, None]: |
| 76 | iteration_count = self.tracker.get('iteration_count', 0) + 1 |
| 77 | self.tracker['iteration_count'] = iteration_count |
| 78 | self.tracker.setdefault('attempt_counts', []).append(ctx.attempt_count) |
| 79 | |
| 80 | if iteration_count < self.succeed_on_iteration: |
| 81 | raise self.exception_to_raise |
| 82 | |
| 83 | yield Event( |
| 84 | output=self.message, |
| 85 | ) |
| 86 | |
| 87 | |
| 88 | async def _run_workflow(wf, message='start'): |
nothing calls this directly
no test coverage detected