diff --git a/tasks.py b/tasks.py index cc79d71..1dc19f9 100644 --- a/tasks.py +++ b/tasks.py @@ -160,6 +160,7 @@ def deferred(self, *args, **kwargs ): except Exception as e: logging.exception(e) raise errors.RequestTimeout() #Task-API should retry + session.current.session.changed = False # Reset session changed marker - don't initialize this session deferred.exposed=True def index(self, *args, **kwargs):