Merge pull request #4322 from pixelfed/staging

Update pipeline dispatch, replace dispatchSync with dispatch
This commit is contained in:
daniel 2023-04-24 01:36:39 -06:00 committed by GitHub
commit 8858960577
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
7 changed files with 7 additions and 7 deletions

View file

@ -102,7 +102,7 @@ class FixMediaDriver extends Command
'image/webp'
])
) {
ImageOptimize::dispatchSync($media);
ImageOptimize::dispatch($media);
sleep(3);
}
} else {

View file

@ -46,7 +46,7 @@ class VideoThumbnail extends Command
->take($limit)
->get();
foreach($videos as $video) {
Pipeline::dispatchSync($video);
Pipeline::dispatch($video);
}
}
}

View file

@ -46,7 +46,7 @@ class ContactController extends Controller
$contact->response = '';
$contact->save();
ContactPipeline::dispatchSync($contact);
ContactPipeline::dispatch($contact);
return redirect()->back()->with('status', 'Success - Your message has been sent to admins.');
}

View file

@ -80,7 +80,7 @@ class DeleteAccountPipeline implements ShouldQueue
$id = $user->profile_id;
Status::whereProfileId($id)->chunk(50, function($statuses) {
foreach($statuses as $status) {
StatusDelete::dispatchSync($status);
StatusDelete::dispatch($status);
}
});

View file

@ -95,7 +95,7 @@ class StatusDelete implements ShouldQueue
Media::whereStatusId($status->id)
->get()
->each(function($media) {
MediaDeletePipeline::dispatchSync($media);
MediaDeletePipeline::dispatch($media);
});
if($status->in_reply_to_id) {

View file

@ -49,7 +49,7 @@ class AdminNewAutospam extends Mailable
$data = $this->report->toArray();
$reported_status = null;
$reported_account = null;
$url = url('/i/admin/reports/autospam/' . $this->report->id);
$url = url('/i/admin/reports/autospam/' . $this->report->id . '?ref=email');
if($data['item_type'] === 'App\Status') {
$reported_status = StatusService::get($this->report->item_id, false);

View file

@ -178,7 +178,7 @@ class Inbox
switch($obj['type']) {
case 'Story':
StoryFetch::dispatchSync($this->payload);
StoryFetch::dispatch($this->payload);
break;
}