@@ -72,11 +72,11 @@ public function retry(?int $id, ?string $queue): int
72
72
$ jobs = model (QueueJobFailedModel::class)
73
73
->when (
74
74
$ id !== null ,
75
- static fn ($ query ) => $ query ->where ('id ' , $ id )
75
+ static fn ($ query ) => $ query ->where ('id ' , $ id ),
76
76
)
77
77
->when (
78
78
$ queue !== null ,
79
- static fn ($ query ) => $ query ->where ('queue ' , $ queue )
79
+ static fn ($ query ) => $ query ->where ('queue ' , $ queue ),
80
80
)
81
81
->findAll ();
82
82
@@ -112,11 +112,11 @@ public function flush(?int $hours, ?string $queue): bool
112
112
return model (QueueJobFailedModel::class)
113
113
->when (
114
114
$ hours !== null ,
115
- static fn ($ query ) => $ query ->where ('failed_at <= ' , Time::now ()->subHours ($ hours )->timestamp )
115
+ static fn ($ query ) => $ query ->where ('failed_at <= ' , Time::now ()->subHours ($ hours )->timestamp ),
116
116
)
117
117
->when (
118
118
$ queue !== null ,
119
- static fn ($ query ) => $ query ->where ('queue ' , $ queue )
119
+ static fn ($ query ) => $ query ->where ('queue ' , $ queue ),
120
120
)
121
121
->delete ();
122
122
}
@@ -129,7 +129,7 @@ public function listFailed(?string $queue): array
129
129
return model (QueueJobFailedModel::class)
130
130
->when (
131
131
$ queue !== null ,
132
- static fn ($ query ) => $ query ->where ('queue ' , $ queue )
132
+ static fn ($ query ) => $ query ->where ('queue ' , $ queue ),
133
133
)
134
134
->orderBy ('failed_at ' , 'desc ' )
135
135
->findAll ();
0 commit comments