diff --git a/lib/Alchemy/Phrasea/Model/Repositories/WorkerRunningJobRepository.php b/lib/Alchemy/Phrasea/Model/Repositories/WorkerRunningJobRepository.php
index 1937774143..a3b584058d 100644
--- a/lib/Alchemy/Phrasea/Model/Repositories/WorkerRunningJobRepository.php
+++ b/lib/Alchemy/Phrasea/Model/Repositories/WorkerRunningJobRepository.php
@@ -97,4 +97,9 @@ class WorkerRunningJobRepository extends EntityRepository
             $this->_em->rollback();
         }
     }
+
+    public function getEntityManager()
+    {
+        return parent::getEntityManager();
+    }
 }
diff --git a/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php b/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php
index 8c60604299..d225a0c37a 100644
--- a/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php
+++ b/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php
@@ -38,10 +38,6 @@ class RecordSubscriber implements EventSubscriberInterface
      * @var callable
      */
     private $appboxLocator;
-    /**
-     * @var WorkerRunningJobRepository
-     */
-    private $repoWorker;
 
     public function __construct(Application $app, callable $appboxLocator)
     {
@@ -49,7 +45,6 @@ class RecordSubscriber implements EventSubscriberInterface
         $this->workerResolver      = $app['alchemy_worker.type_based_worker_resolver'];
         $this->app                 = $app;
         $this->appboxLocator       = $appboxLocator;
-        $this->repoWorker          = $app['repo.worker-running-job'];
     }
 
     public function onSubdefinitionCreate(SubdefinitionCreateEvent $event)
@@ -104,8 +99,9 @@ class RecordSubscriber implements EventSubscriberInterface
             ]
         ];
 
-        $em = $this->repoWorker->getEntityManager();
-        $workerRunningJob = $this->repoWorker->findOneBy([
+        $repoWorker = $this->getRepoWorker();
+        $em = $repoWorker->getEntityManager();
+        $workerRunningJob = $repoWorker->findOneBy([
             'databoxId' => $event->getRecord()->getDataboxId(),
             'recordId'  => $event->getRecord()->getRecordId(),
             'work'       => PhraseaTokens::MAKE_SUBDEF,
@@ -225,8 +221,9 @@ class RecordSubscriber implements EventSubscriberInterface
 
             $jeton = ($event->getSubdefName() == "document") ? PhraseaTokens::WRITE_META_DOC : PhraseaTokens::WRITE_META_SUBDEF;
 
-            $em = $this->repoWorker->getEntityManager();
-            $workerRunningJob = $this->repoWorker->findOneBy([
+            $repoWorker = $this->getRepoWorker();
+            $em = $repoWorker->getEntityManager();
+            $workerRunningJob = $repoWorker->findOneBy([
                 'databoxId' => $event->getRecord()->getDataboxId(),
                 'recordId'  => $event->getRecord()->getRecordId(),
                 'work'       => $jeton,
@@ -323,4 +320,12 @@ class RecordSubscriber implements EventSubscriberInterface
 
         return $callable();
     }
+
+    /**
+     * @return WorkerRunningJobRepository
+     */
+    private function getRepoWorker()
+    {
+        return $this->app['repo.worker-running-job'];
+    }
 }