throw=True
This commit is contained in:
parent
9182b966e3
commit
c4b7597772
@ -28,7 +28,7 @@ def main():
|
|||||||
module, name = args.task.rsplit('.', 1)
|
module, name = args.task.rsplit('.', 1)
|
||||||
task = getattr(__import__(module, fromlist=[name]), name)
|
task = getattr(__import__(module, fromlist=[name]), name)
|
||||||
for doc in docs:
|
for doc in docs:
|
||||||
task(doc['_id'])
|
task.apply((doc['_id'],), throw=True)
|
||||||
|
|
||||||
else:
|
else:
|
||||||
for doc in docs:
|
for doc in docs:
|
||||||
|
Loading…
Reference in New Issue
Block a user