@@ -88,13 +88,14 @@ use Symfony\Component\HttpKernel\KernelInterface;
8888use Symfony\Component\Serializer\Normalizer\DenormalizerInterface;
8989use Yokai\Batch\Bridge\Doctrine\Persistence\ObjectWriter;
9090use Yokai\Batch\Bridge\Symfony\Serializer\DenormalizeItemProcessor;
91+ use Yokai\Batch\Job\AbstractDecoratedJob;
9192use Yokai\Batch\Job\Item\ItemJob;
9293use Yokai\Batch\Job\Item\Reader\Filesystem\JsonLinesReader;
9394use Yokai\Batch\Job\Parameters\DefaultParameterAccessor;
9495use Yokai\Batch\Job\Parameters\JobExecutionParameterAccessor;
9596use Yokai\Batch\Storage\JobExecutionStorageInterface;
9697
97- final class ImportUsersJob extends ItemJob
98+ final class ImportUsersJob extends AbstractDecoratedJob
9899{
99100 public function __construct(
100101 JobExecutionStorageInterface $executionStorage,
@@ -103,16 +104,18 @@ final class ImportUsersJob extends ItemJob
103104 KernelInterface $kernel,
104105 ) {
105106 parent::__construct(
106- 500,
107- new JsonLinesReader(
108- new DefaultParameterAccessor(
109- new JobExecutionParameterAccessor('importFile'),
110- $kernel->getProjectDir() . '/var/import/users.jsonl'
111- )
112- ),
113- new DenormalizeItemProcessor($denormalizer, User::class),
114- new ObjectWriter($doctrine),
115- $executionStorage
107+ new ItemJob(
108+ 500,
109+ new JsonLinesReader(
110+ new DefaultParameterAccessor(
111+ new JobExecutionParameterAccessor('importFile'),
112+ $kernel->getProjectDir() . '/var/import/users.jsonl'
113+ )
114+ ),
115+ new DenormalizeItemProcessor($denormalizer, User::class),
116+ new ObjectWriter($doctrine),
117+ $executionStorage
118+ )
116119 );
117120 }
118121}
0 commit comments