3

对于某个 Laravel Horizo​​n 作业,我有一个函数可以根据 Horizo​​n 存储库检查特定模型的作业当前是否正在运行:

public static function isRunning($model)
{        
    $tag = self::getTag($model);
    $tagRepository = app()->make(TagRepository::class);
    $jobRepository = app()->make(JobRepository::class);
    $jobIds = $tagRepository->jobs($tag);
    $jobs = $jobRepository->getJobs($jobIds);
    $runningJobs = collect($jobs)->reject(function($job) {
        return $job->status === HorizonRedisJobStatuses::STATUS_COMPLETED // 'completed'
            || $job->status === HorizonRedisJobStatuses::STATUS_FAILED; // 'failed'
    });

    return $runningJobs->count() > 0;
}

此代码大部分时间都有效,但是,有时会因为超时而重新启动此类作业。在这种情况下,我在$jobs变量中的所有作业都标记为"completed",因此函数返回false。似乎重新启动的作业没有填充到存储库中。

目前,我想出的唯一解决方法是在进程开始/结束时在数据库中手动跟踪作业状态,但是,如果,例如,Horizo​​n 尝试用完,这仍然会给我错误的结果。

那么有没有人知道如何正确跟踪 Horizo​​n 中的工作状态?

4

1 回答 1

0

我将它作为一个错误发布在 Horizo​​n Github 上,它已在拉取请求中修复https://github.com/laravel/horizo ​​n/pull/478

现在示例中的代码应该可以正常工作了。

于 2019-01-29T13:08:31.397 回答