请问 celery 不符合要求就丢弃 不加入队列,如何做呢

2015-03-17 18:15:37 +08:00
 9xrtp7r1

celery 每10秒某个任务, 这个任务里有个判断,如果符合要求 就执行,否则就丢弃 有什么思路吗,我测试, 不符合 直接return 0 他还是会把这个任务加入队列里面执行 有没有办法让他不符合的情况下 直接丢弃 不加入执行队列呀

from datetime import timedelta

CELERYBEAT_SCHEDULE = {
'add-every-10-seconds': {
'task': 'celery01.tasks.SingleTask',
'schedule': timedelta(seconds=10)

},

}


def SingleTask(name):
if name=="go":
print("run")
else:
return 0 #不符合条件,不做任何执行

2423 次点击
所在节点    问与答
3 条回复
kslr
2015-03-17 19:41:03 +08:00
不符合就不执行函数呗
20150517
2015-03-17 20:23:16 +08:00
raise RuntimeException("")
就跳过了
9xrtp7r1
2015-03-18 11:42:35 +08:00
@kslr
@20150517

谢谢,我今天重新运行 发现 好像他不会积压任务了, 也就是 重复提交 不会加入队列了,那暂时就这样,能运行就好 多谢了

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/177562

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX