mirror of
https://github.com/archtechx/jobpipeline.git
synced 2025-12-12 13:34:03 +00:00
fix style
This commit is contained in:
parent
80947a4889
commit
d636ab5fe3
1 changed files with 4 additions and 4 deletions
|
|
@ -5,8 +5,9 @@ declare(strict_types=1);
|
||||||
namespace Stancl\JobPipeline;
|
namespace Stancl\JobPipeline;
|
||||||
|
|
||||||
use Closure;
|
use Closure;
|
||||||
use Throwable;
|
|
||||||
use Illuminate\Contracts\Queue\ShouldQueue;
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Throwable;
|
||||||
|
|
||||||
class JobPipeline implements ShouldQueue
|
class JobPipeline implements ShouldQueue
|
||||||
{
|
{
|
||||||
|
|
@ -66,9 +67,8 @@ class JobPipeline implements ShouldQueue
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$result = app()->call($job);
|
$result = app()->call($job);
|
||||||
} catch(Throwable $exception) {
|
} catch (Throwable $exception) {
|
||||||
if ( method_exists(get_class($job[0]), 'failed') ) {
|
if (method_exists(get_class($job[0]), 'failed')) {
|
||||||
|
|
||||||
call_user_func_array([$job[0], 'failed'], [$exception]);
|
call_user_func_array([$job[0], 'failed'], [$exception]);
|
||||||
} else {
|
} else {
|
||||||
Log::error($exception);
|
Log::error($exception);
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue