eee

2025-07-11 15:04:25 +08:00
parent 7b8a43f94f
commit e399837dad
1 changed files with 6 additions and 10 deletions
@@ -72,10 +72,7 @@ class Task
     */
    public function onTask(Server $server, int $task_id, int $src_worker_id, mixed $data): void
    {
-        $response = 'task data format failed.';
        try {
-            $data = json_decode($data, true);
-            if (!is_null($data)) {
            [$handler, $params] = [$data[0], $data[1]];

            $handler = Kiri::getDi()->make($handler, $params);
@@ -84,7 +81,6 @@ class Task
            }

            $response = call_user_func([$handler, 'process'], $task_id, $src_worker_id);
-            }
        } catch (\Throwable $throwable) {
            $response = throwable($throwable);
        } finally {