对于某个 Laravel Horizon 作业,我有一个函数可以根据 Horizon 存储库检查特定模型的作业当前是否正在运行:
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
。似乎重新启动的作业没有填充到存储库中。
目前,我想出的唯一解决方法是在进程开始/结束时在数据库中手动跟踪作业状态,但是,如果,例如,Horizon 尝试用完,这仍然会给我错误的结果。
那么有没有人知道如何正确跟踪 Horizon 中的工作状态?