PipelineTask: handle cancellations gracefully

This commit is contained in:
Aleix Conchillo Flaqué
2025-08-22 18:53:00 -07:00
parent db3b8c7325
commit a0128516ff
2 changed files with 33 additions and 6 deletions

View File

@@ -341,6 +341,8 @@ async def run_eval_pipeline(
async def on_pipeline_idle_timeout(task):
await eval_runner.assert_eval_false()
runner = PipelineRunner()
# TODO(aleix): We should handle SIGINT and SIGTERM so we can cancel both the
# eval and the example.
runner = PipelineRunner(handle_sigint=False)
await runner.run(task)