使用芹菜作为后端的concurrent.futures.executor实现
celery-executor的Python项目详细描述
芹菜执行器
以芹菜为后端的concurrent.futures.Executor
实现
- 免费软件:apache软件许可证2.0
- 文档:https://celery-executor.readthedocs.io。
功能
该包提供了一个实现
^{
>>>fromcelery_executor.executorsimportCeleryExecutor>>>executor=CeleryExecutor()>>>forresultinexecutor.map(str.upper,['one','two','three']):...print(result)ONETWOTHREE
注意Executor.map()
接口可能会导致结果无序,
如果后面的人必须先完成。
注意事项
这个执行器使开发人员免除了标记每个任务的负担。 与芹菜装饰工一起工作,并将这些任务导入到工人身上 事先。但不能免除将代码发送给工作者的责任。
发送到CeleryExecutor.map()
的函数应在客户端上可拾取
(呼叫者是.map()
或.submit()
),在芹菜上应该是不可吃的。
处理发送的“任务”的工人。例如,无法发送lambdas。
因为芹菜假设开发人员将所需的代码放在工作人员身上, 请确保发送到^ {CD2}}的函数/部分代码存在于 工人。
待完成
- []记录
CeleryExecutor.__init__()
非标准额外选项predelay
、postdelay
和applyasync_kwargs
。 - []测试取消未来时取消任务的行为
- []测试关闭执行器并尝试发送新任务的行为
- []找到一种方法来测试芹菜任务的运行状态,因为芹菜提供的测试工作人员不会传播芹菜任务的事件
学分
这个包是用Cookiecutter和^{
======= 历史记录
0.1.0(2018-05-25)
- pypi上的第一个版本。