0

我尝试使用此解决方案但没有成功。如何指定应在一个月中的哪一天执行任务？我的解决方案是

class DayOfMonth(schedule):

    def __init__(self, day=1):
        self.day = day

    def is_due(self, last_run_at):
        now = datetime.datetime.now()
        if now.month != last_run_at.month and now.day == self.day:
            return True, 3000
        return False, 3000

    def __eq__(self, other):
            if isinstance(other, DayOfMonth):
                return self.day == other.day and self.month == other.month
            return False

我尝试使用 django-celery 运行它，但我仍然收到未指定 run_every 的错误。

编辑1：

我运行我的任务添加：

"my_task": {
        "task": "util.tasks.CeleryManagementCommand",
        "schedule": DayOfMonth(day=4),
        "args": ('my_task',),
    },

CELERYBEAT_SHEDULE听写_

编辑2：

当我在init中指定 run_every ->self.run_every = None我收到 None 类型对象没有属性 total_seconds 的错误

4

1 回答 1

1

如果您子类化并更改init，您最好确保调用父级的init。我很确定这将解决您的问题：

class DayOfMonth(schedule):

    def __init__(self, day=1, *args, **kwargs):
        super(DayOfMonth, self).__init__(*args, **kwargs)
        self.day = day

如果您检查这一点，它将阐明您遇到的错误： https ://github.com/ask/celery/blob/master/celery/schedules.py#L33

于 2012-04-06T16:38:10.187 回答