test

taipy/core/_orchestrator/_dispatcher/_development_job_dispatcher.py

@@ -50,5 +50,5 @@ class _DevelopmentJobDispatcher(_JobDispatcher):
     def _is_dispatched(self, job_id: str) -> bool:
         return False
 
-    def _remove_job(self, job_id: str):
+    def _remove_dispatched_job(self, job_id: str):
         pass

taipy/core/_orchestrator/_dispatcher/_job_dispatcher.py

@@ -146,5 +146,5 @@ class _JobDispatcher(threading.Thread):
         raise NotImplementedError
 
     @abstractmethod
-    def _remove_job(self, job_id: str):
+    def _remove_dispatched_job(self, job_id: str):
         raise NotImplementedError

taipy/core/_orchestrator/_dispatcher/_standalone_job_dispatcher.py

@@ -76,5 +76,5 @@ class _StandaloneJobDispatcher(_JobDispatcher):
     def _is_dispatched(self, job_id: str) -> bool:
         return job_id in self._dispatched_processes.keys()
 
-    def _remove_job(self, job_id: str):
+    def _remove_dispatched_job(self, job_id: str):
         self._pop_dispatched_process(job_id)

taipy/core/_orchestrator/_orchestrator.py

@@ -329,6 +329,3 @@ class _Orchestrator(_AbstractOrchestrator):
 
         if dispatcher := _OrchestratorFactory._dispatcher:
             dispatcher._execute_jobs_synchronously()
-
-    def is_dispatched(self, job_id: JobId) -> bool:
-        raise NotImplementedError

taipy/core/job/_job_manager.py

@@ -63,7 +63,7 @@ class _JobManager(_Manager[Job], _VersionMixin):
             super()._delete(job.id)
             from .._orchestrator._orchestrator_factory import _OrchestratorFactory
 
-            _OrchestratorFactory._dispatcher._remove_job(job.id)  # type: ignore
+            _OrchestratorFactory._dispatcher._remove_dispatched_job(job.id)  # type: ignore
         else:
             err = JobNotDeletedException(job.id)
             cls._logger.error(err)