This commit is contained in:
2024-12-27 18:21:30 +08:00
parent faff485006
commit a058f3ed99
+4 -2
View File
@@ -77,8 +77,10 @@ class Task
if (is_null($data)) { if (is_null($data)) {
return null; return null;
} }
$data[0] = Kiri::getDi()->get($data[0]); [$handler, $params] = $data;
return call_user_func($data, $task_id, $src_worker_id);
$handler[0] = Kiri::getDi()->get($handler[0]);
return call_user_func($handler, $task_id, $src_worker_id, $params);
} catch (\Throwable $throwable) { } catch (\Throwable $throwable) {
return $this->exception->emit($throwable, response()); return $this->exception->emit($throwable, response());
} }