diff --git a/Task/Task.php b/Task/Task.php index 4104c74..e53acf5 100644 --- a/Task/Task.php +++ b/Task/Task.php @@ -77,8 +77,10 @@ class Task if (is_null($data)) { return null; } - $data[0] = Kiri::getDi()->get($data[0]); - return call_user_func($data, $task_id, $src_worker_id); + [$handler, $params] = $data; + + $handler[0] = Kiri::getDi()->get($handler[0]); + return call_user_func($handler, $task_id, $src_worker_id, $params); } catch (\Throwable $throwable) { return $this->exception->emit($throwable, response()); }