From 101cb2ff7aba8cb02d2df90ce502dc3fe4d2cbfa Mon Sep 17 00:00:00 2001 From: ryan Date: Sat, 29 Aug 2026 08:35:00 +0800 Subject: [PATCH] autoresearch iter 12: inproc driver reports untracked executions as an error GetExecution returned (nil, nil) under the in-process driver where the asynq driver returns an error, so the same contract call meant 'empty' in one deployment mode and 'failed' in the other. --- backend/plugins/drivers/driver_inproc_worker/task_service.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/backend/plugins/drivers/driver_inproc_worker/task_service.go b/backend/plugins/drivers/driver_inproc_worker/task_service.go index 687493ea..bbeb0beb 100644 --- a/backend/plugins/drivers/driver_inproc_worker/task_service.go +++ b/backend/plugins/drivers/driver_inproc_worker/task_service.go @@ -7,6 +7,7 @@ import ( "Wavelet/core/contracts" "Wavelet/core/extpoints" "context" + "errors" "fmt" ) @@ -77,5 +78,5 @@ func (s *inprocTaskService) ListExecutions(_ context.Context, _, _ string, _, _ } func (s *inprocTaskService) GetExecution(_ context.Context, _ uint64) (*contracts.TaskExecutionDTO, error) { - return nil, nil + return nil, errors.New("driver_inproc_worker: task executions are not tracked") }