From 5f426ad33ddc02c8f992fa1c22ffd6de17d2b114 Mon Sep 17 00:00:00 2001 From: Lodewijk Nauta Date: Fri, 6 Sep 2024 11:14:12 +0200 Subject: [PATCH] Change actor names for backwards compatibility --- picas/actors.py | 6 +++--- tests/test_mock.py | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/picas/actors.py b/picas/actors.py index 8cab44a..8d82974 100644 --- a/picas/actors.py +++ b/picas/actors.py @@ -18,7 +18,7 @@ log = logging.getLogger(__name__) -class RunActor(object): +class AbstractRunActor(object): """ Executor class to be overwritten in the client implementation. """ @@ -162,7 +162,7 @@ def cleanup_env(self, *args, **kwargs): """ -class RunActorWithStop(RunActor): +class RunActor(AbstractRunActor): """ RunActor class with added stopping functionality. """ @@ -218,4 +218,4 @@ def run(self, max_time=None, avg_time_factor=0.0, max_tasks=0, stop_function=Non break self.current_task = None # set to None so the handler leaves the token alone when picas is killed finally: - self.cleanup_env() \ No newline at end of file + self.cleanup_env() diff --git a/tests/test_mock.py b/tests/test_mock.py index 553fbe7..aa3d34a 100644 --- a/tests/test_mock.py +++ b/tests/test_mock.py @@ -1,5 +1,5 @@ import random -from picas.actors import RunActor, RunActorWithStop +from picas.actors import AbstractRunActor, RunActor from picas.documents import Document @@ -40,7 +40,7 @@ def save(self, doc): return doc -class MockRun(RunActor): +class MockRun(AbstractRunActor): def __init__(self, callback): db = MockDB() @@ -52,7 +52,7 @@ def process_task(self, task): self.callback(task) -class MockRunWithStop(RunActorWithStop): +class MockRunWithStop(RunActor): def __init__(self, callback): db = MockDB()