Laravel 5.5 Job Chaining: вызов неопределенного метода::chain()
У меня есть две работы, первая из которых должна быть отослана, вторая перед запуском, я нахожу цепочку заданий, но не могу заставить ее работать, все задания настраиваются из коробки, поэтому теоретически это должно работать. Вот моя первая работа:
namespace App\Jobs;
class MCSendJob
{
use Dispatchable, InteractsWithQueue;
public function handle(Config $config, MCReport $report)
{
if ($config->mcdb_status) {
$report->setConnection('mcdb');
} elseif ($config->rmcdb_status) {
$report->setConnection('rmcdb');
} else {
$this->fail(new \Exception('No active MCDB connection found!'));
}
$models = collect([
'appoitments' => Appointment::sent(false)->get(),
'questions' => Question::sent(false)->get(),
'price-clarifications' => PriceClarification::sent(false)->get(),
])->flatten(1);
foreach ($models as $model) {
$report->fill((new MCResource($model))->resolve());
$report->save();
$model->update(['mc_sent' => true]);
}
Log::info('MCSend done.');
}
}
второй:
namespace App\Jobs;
class MCCheckJob
{
use Dispatchable, Queueable, MailerDriverMail;
protected $dbConnection;
public function __construct($dbConnection)
{
$this->dbConnection = $dbConnection;
}
public function handle(Config $config)
{
try {
DB::connection($this->dbConnection)->getPdo();
$config->{$this->dbConnection . '_status'} = true;
$config->save();
Log::info('MCCheck done.');
} catch (PDOException $exception) {
if ($this->dbConnection === 'mcdb') {
Log::error('MCDB connection unavailable!');
$config->mcdb_status = false;
static::dispatch('rmcdb');
} else {
Log::error('RMCDB connection unavailable!');
$config->rmcdb_status = false;
}
$config->save();
Log::error('SQLSrv PDO Exception', ['error_code' => $exception->getErrorCode(), 'error_info' => $exception->getMessage()]);
if(!empty($config->mailing_list_mc_reports)) {
Mail::to($config->mailing_list_mc_reports)->send(new MCNoConnectionWarning($this->dbConnection));
}
}
}
}
Когда я пытаюсь отправить работу с помощью цепочки, вот так: MCSendJob::dispatch()->chain([new MCCheckJob('mcdb')])
, или это: MCSendJob::withChain([new MCCheckJob('mcdb')])->dispatch();
Я получаю следующую ошибку: Call to undefined method App\Jobs\MCSendJob::chain()
, Я нахожу этот метод в Illuminate\Foundation\Bus\PendingDispatch
,
Не могу понять - где проблема.
1 ответ
У меня была такая же проблема, и это было как-то связано с неисправной более ранней версией скрипта, загружаемой в память Horizon.
Быстрый перезапуск Horizon, и все снова работает нормально.
У меня была такая же проблема, решилась перезапуском супервизора:
service supervisord stop
service supervisord force-reload