arq工作者-学习: python

Question

告诉我..。如何在python中为arq作业设置工作人员。

我搞错了

断言len(self.functions) > 0，“至少一个函数或cron_job必须注册”AssertionError:至少一个函数或cron_job必须注册

Answer 1

您需要一个工作人员应该运行的函数。否则，工人将是相当不必要的。

例如，使用函数the_tasks，可以将其添加到工作人员的functions参数中：

arq import Worker

async def the_task(ctx):
    print('running the task')
    return 42

w = Worker(functions=[the_task],
    redis_settings=WorkerSettings.redis_settings(),
    max_jobs=1000,
    keep_result_forever=True,
    job_timeout=86000,
    max_tries=1000)
w.run()

也许从演示示例开始：https://arq-docs.helpmanual.io/#simple-usage