Skip to content

Commit

Permalink
Change actor names for backwards compatibility
Browse files Browse the repository at this point in the history
  • Loading branch information
lnauta committed Sep 6, 2024
1 parent ee69025 commit 5f426ad
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
6 changes: 3 additions & 3 deletions picas/actors.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
log = logging.getLogger(__name__)


class RunActor(object):
class AbstractRunActor(object):
"""
Executor class to be overwritten in the client implementation.
"""
Expand Down Expand Up @@ -162,7 +162,7 @@ def cleanup_env(self, *args, **kwargs):
"""


class RunActorWithStop(RunActor):
class RunActor(AbstractRunActor):
"""
RunActor class with added stopping functionality.
"""
Expand Down Expand Up @@ -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()
self.cleanup_env()
6 changes: 3 additions & 3 deletions tests/test_mock.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import random
from picas.actors import RunActor, RunActorWithStop
from picas.actors import AbstractRunActor, RunActor
from picas.documents import Document


Expand Down Expand Up @@ -40,7 +40,7 @@ def save(self, doc):
return doc


class MockRun(RunActor):
class MockRun(AbstractRunActor):

def __init__(self, callback):
db = MockDB()
Expand All @@ -52,7 +52,7 @@ def process_task(self, task):
self.callback(task)


class MockRunWithStop(RunActorWithStop):
class MockRunWithStop(RunActor):

def __init__(self, callback):
db = MockDB()
Expand Down

0 comments on commit 5f426ad

Please sign in to comment.