对于某个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中正确跟踪作业状态?
https://stackoverflow.com/questions/51324850
复制相似问题