@@ -61,9 +61,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
6161 //====================================================================//
6262 // Load Tasks Repository
6363 /** @var TaskRepository $repo */
64- $ repo = $ this ->getContainer ()
65- ->get ("doctrine " )->getManager ()
66- ->getRepository (Task::class);
64+ $ repo = $ this ->getContainer ()->get ("splash.tasking.tasks " )->getTasksRepository ();
6765
6866 while (1 ) {
6967 //====================================================================//
@@ -108,9 +106,7 @@ protected function showWorkers(OutputInterface $output): void
108106 //====================================================================//
109107 // Load Tasks Repository
110108 /** @var WorkerRepository $repo */
111- $ repo = $ this ->getContainer ()
112- ->get ("doctrine " )->getManager ()
113- ->getRepository (Worker::class);
109+ $ repo = $ this ->getContainer ()->get ("splash.tasking.tasks " )->getWorkerRepository ();
114110
115111 //====================================================================//
116112 // List Workers Status
@@ -156,9 +152,7 @@ protected function getWorkersStatusStr()
156152 //====================================================================//
157153 // Load Worker Repository
158154 /** @var WorkerRepository $workers */
159- $ workers = $ this ->getContainer ()
160- ->get ("doctrine " )->getManager ()
161- ->getRepository (Worker::class);
155+ $ workers = $ this ->getContainer ()->get ("splash.tasking.tasks " )->getWorkerRepository ();
162156 //====================================================================//
163157 // Fetch Workers Status
164158 $ status = $ workers ->getWorkersStatus ();
0 commit comments