worker = $worker; } public function handle(): void { $this->worker->server->processManager()->handler()->create( $this->worker->id, $this->worker->command, $this->worker->user, $this->worker->auto_start, $this->worker->auto_restart, $this->worker->numprocs, $this->worker->log_file, $this->worker->site_id ); $this->worker->status = QueueStatus::RUNNING; $this->worker->save(); event( new Broadcast('deploy-queue-finished', [ 'queue' => $this->worker, ]) ); } public function failed(): void { $this->worker->delete(); event( new Broadcast('deploy-queue-failed', [ 'queue' => $this->worker, ]) ); } }