Fix paused tasks.
This commit is contained in:
parent
b4283a642b
commit
f0bae25ca0
1 changed files with 1 additions and 1 deletions
|
|
@ -292,7 +292,7 @@ class DefaultScript(ScriptBase):
|
||||||
def at_idmapper_flush(self):
|
def at_idmapper_flush(self):
|
||||||
"""If we're flushing this object, make sure the LoopingCall is gone too"""
|
"""If we're flushing this object, make sure the LoopingCall is gone too"""
|
||||||
ret = super(DefaultScript, self).at_idmapper_flush()
|
ret = super(DefaultScript, self).at_idmapper_flush()
|
||||||
if ret:
|
if ret and self.ndb._task:
|
||||||
try:
|
try:
|
||||||
from twisted.internet import reactor
|
from twisted.internet import reactor
|
||||||
global FLUSHING_INSTANCES
|
global FLUSHING_INSTANCES
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue