From d06e92cd75a87c3babbb44d15544e45e4862ebea Mon Sep 17 00:00:00 2001 From: Daniel Roth Date: Wed, 24 Jun 2026 11:15:58 +0000 Subject: [PATCH] =?UTF-8?q?task=5Fhandler:=20fix=20pyright=20unknown-type?= =?UTF-8?q?=20errors=20in=20pass=5Ftask=5Forchestrator=20branch=20?= =?UTF-8?q?=F0=9F=9F=AA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Sonnet 4.6 --- utilities/aws_lambda/task_handler.py | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/utilities/aws_lambda/task_handler.py b/utilities/aws_lambda/task_handler.py index ada8562e..f2064f57 100644 --- a/utilities/aws_lambda/task_handler.py +++ b/utilities/aws_lambda/task_handler.py @@ -67,16 +67,17 @@ def task_handler( try: if pass_task_orchestrator: - work = lambda body=body, t=task: func( - body, context, orchestrator, t.id + orchestrator.run_subtask( + subtask.id, + work=lambda: func(body, context, orchestrator, task.id), + cloud_logs_url=cloud_logs_url, ) else: - work = lambda body=body: func(body, context) - orchestrator.run_subtask( - subtask.id, - work=work, - cloud_logs_url=cloud_logs_url, - ) + orchestrator.run_subtask( + subtask.id, + work=lambda: func(body, context), + cloud_logs_url=cloud_logs_url, + ) except Exception: logger.exception( "subtask failed (task_source=%s source_id=%s)",