我有一个这样的链:
chain = file_transfer.s(password, source12, destination1) | save_db.s(request.user.id, basename, extension, servername, start_date1, datetime.datetime.utcnow().replace(tzinfo=utc)
在调用save_db.s
时,我想调用以获取end_date
,这就是为什么我使用datetime.datetime.utcnow().replace(tzinfo=utc)
来计算end_date。问题是它计算任务启动的日期。如何获取每个任务的end_date并将其保存在数据库中以备将来使用。感谢
如果您还记得save_db.s
将获得file_transfer.s
的结果作为第一个参数。因此,您可以将file_transfer.s
的结果作为带日期时间的元组返回。
示例:
从django.utils.timezone立即导入
def file_transfer(...): ... return (now(), ...) def save_db(end_date, ...): ...