You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Laravel调度任务未失败却触发失败事件及Telescope状态异常问题

问题原因分析

你遇到的核心问题是混淆了调度器回调与队列任务执行结果的监控范围:

Laravel调度器的onSuccess/onFailure回调,监控的是「调度任务是否成功将Job推送到队列」,而不是Job本身的执行结果。哪怕你用的是sync队列驱动,->job()方法依然会把任务当作队列任务处理——调度器只负责把Job dispatch出去,至于Job执行成功与否,调度器根本不知情,这就导致了正常执行的任务被误判为失败。

另外Telescope显示pending,也是因为调度器把Job当作队列任务处理,而sync驱动下的状态更新逻辑和调度器的任务状态统计不匹配导致的。


解决方案

根据你是否需要队列异步执行,提供两种针对性方案:

方案1:不需要队列,同步执行任务

如果这个任务不需要异步执行,直接同步跑完即可,两种实现方式:

方式A:修改Job类,移除ShouldQueue接口

你的ProcessPartialDiscountPayments当前实现了ShouldQueue,这会让调度器把它当作队列任务处理。去掉这个接口:

// 原代码
class ProcessPartialDiscountPayments implements ShouldQueue { ... }

// 修改后
class ProcessPartialDiscountPayments {
    // 保留原有use Trait:Dispatchable, InteractsWithQueue, Queueable, SerializesModels(不影响)
    // ... 其他代码不变 ...
}

修改后,调度器的->job()方法会同步执行Job的handle()方法,此时onSuccess和onFailure会根据handle()是否抛出异常触发:正常执行触发onSuccess,抛出异常才触发onFailure。

方式B:用调度器call()方法替代job()

如果不想修改Job类,直接在调度器中同步执行任务逻辑:

$schedule->call(function () {
    $job = new ProcessPartialDiscountPayments();
    $job->handle();
})
->onSuccess(function () {
    Log::info('ProcessPartialDiscountPayments scheduled task successfully ran');
})
->onFailure(function () {
    Log::info('ProcessPartialDiscountPayments errored and did not complete');
})
->emailOutputOnFailure(config('app.webmaster_email'));

方案2:需要队列异步执行任务

如果必须用队列,那调度器的回调就不适合监控Job执行结果了,改用Laravel队列的原生失败处理机制:

步骤1:在Job类中添加failed()方法

Laravel队列任务可以定义failed()方法,当任务执行失败(抛出异常)时会自动调用:

use Illuminate\Support\Facades\Mail;
// 假设你有自定义失败通知邮件类,没有的话可以先创建
use App\Mail\JobFailedNotification;

class ProcessPartialDiscountPayments implements ShouldQueue {
    // ... 原有代码 ...

    /**
     * 任务执行失败时触发
     */
    public function failed(\Throwable $exception)
    {
        // 记录失败日志(带上异常信息便于排查)
        Log::info('ProcessPartialDiscountPayments errored and did not complete', [
            'exception_msg' => $exception->getMessage(),
            'trace' => $exception->getTraceAsString()
        ]);
        
        // 发送失败通知邮件
        Mail::to(config('app.webmaster_email'))->send(new JobFailedNotification($this, $exception));
    }
}

步骤2:清理调度器的无关回调

调度器的onSuccess/onFailure和emailOutputOnFailure是针对「推送Job到队列」这个动作的,和Job执行结果无关,直接移除:

$schedule->job(new ProcessPartialDiscountPayments);

关于Telescope状态异常的说明

按照上述方案修改后:

  • 如果用方案1(同步执行),调度器任务会在Telescope的Scheduled Jobs标签下显示completed状态;
  • 如果用方案2(队列执行),sync驱动下Job执行完成后会在Telescope的Queue标签下显示completed状态。

内容的提问来源于stack exchange,提问作者tuscan88

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.05.14 09:17:58