shouldThrowException) { $job->fail($this->shouldThrowException->getMessage()); return $job; } $job->complete(); return $job; } public function simulateError(\Exception $exception): void { $this->shouldThrowException = $exception; } public function supports(string $sourceType): bool { return true; } }