mirror of
https://github.com/code-rhapsodie/dataflow-bundle.git
synced 2026-03-24 06:42:23 +01:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0938f7fd1e |
@@ -1,3 +1,6 @@
|
||||
# Version 5.3.1
|
||||
* Fix interface naming
|
||||
|
||||
# Version 5.3.0
|
||||
* Added auto update count processed item while running job
|
||||
|
||||
|
||||
@@ -4,7 +4,7 @@ declare(strict_types=1);
|
||||
|
||||
namespace CodeRhapsodie\DataflowBundle\Processor;
|
||||
|
||||
use CodeRhapsodie\DataflowBundle\DataflowType\RepositoryInterface;
|
||||
use CodeRhapsodie\DataflowBundle\DataflowType\AutoUpdateCountInterface;
|
||||
use CodeRhapsodie\DataflowBundle\DataflowType\Result;
|
||||
use CodeRhapsodie\DataflowBundle\Entity\Job;
|
||||
use CodeRhapsodie\DataflowBundle\Event\Events;
|
||||
@@ -31,7 +31,7 @@ class JobProcessor implements JobProcessorInterface, LoggerAwareInterface
|
||||
$this->beforeProcessing($job);
|
||||
|
||||
$dataflowType = $this->registry->getDataflowType($job->getDataflowType());
|
||||
if ($dataflowType instanceof RepositoryInterface) {
|
||||
if ($dataflowType instanceof AutoUpdateCountInterface) {
|
||||
$dataflowType->setRepository($this->repository);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user