From bf00467f633ae6a8523189c1b922ca6dcd6636b8 Mon Sep 17 00:00:00 2001 From: Barry Warsaw Date: Mon, 6 Apr 2015 22:12:37 -0400 Subject: Check pointing --- src/mailman/app/workflow.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/mailman/app/workflow.py') diff --git a/src/mailman/app/workflow.py b/src/mailman/app/workflow.py index bba5bb694..f9a951157 100644 --- a/src/mailman/app/workflow.py +++ b/src/mailman/app/workflow.py @@ -38,11 +38,11 @@ log = logging.getLogger('mailman.error') class Workflow: """Generic workflow.""" - SAVE_KEY = '' SAVE_ATTRIBUTES = () INITIAL_STATE = None def __init__(self): + self.token = None self._next = deque() self.push(self.INITIAL_STATE) @@ -68,7 +68,7 @@ class Workflow: raise def save(self): - assert self.SAVE_KEY, 'Workflow SAVE_KEY must be set' + assert self.token, 'Workflow token must be set' state_manager = getUtility(IWorkflowStateManager) data = {attr: getattr(self, attr) for attr in self.SAVE_ATTRIBUTES} # Note: only the next step is saved, not the whole stack. This is not @@ -86,13 +86,13 @@ class Workflow: "in the queue") state_manager.save( self.__class__.__name__, - self.SAVE_KEY, + self.token, step, json.dumps(data)) def restore(self): state_manager = getUtility(IWorkflowStateManager) - state = state_manager.restore(self.__class__.__name__, self.SAVE_KEY) + state = state_manager.restore(self.__class__.__name__, self.token) if state is not None: self._next.clear() if state.step: -- cgit v1.2.3-70-g09d2