跳转到主要内容

Celery批量任务

项目描述

bulk-task

bulk-task包提供了一个批量调用延迟函数的简单方法。

安装

$ pip install bulk-task

示例

from dataclasses import dataclass
from bulk_task import BulkTask


bulk_task = BulkTask()


# It can be a dataclass or a Pydantic model.
@dataclass
class DataclassModel:
    name: str


@bulk_task
def func(args: List[DataclassModel]):
    print(arg.name for arg in args)


# Push lazy calls.
func.push('name1')
func.push('name2')

# Bulk consume lazy calls.
bulk_task.consume()

项目详情


下载文件

下载适合您平台的文件。如果您不确定选择哪个,请了解有关 安装包 的更多信息。

源分发

bulk_task-0.0.2.tar.gz (4.0 kB 查看哈希值)

上传时间:

构建分发

bulk_task-0.0.2-py3-none-any.whl (4.8 kB 查看哈希值)

上传时间 Python 3

由以下支持