v0.11.0
- Added ability to optionally pass
ctxto the task, like this:
@task(with_ctx=True)
def foobar(ctx):
log.info('Foobar try %s', ctx['job_try'])ctx contains: job_id, job_try, enqueue_time, score, metadata + all worker's ctx (including custom context which can be passed via on_startup). Thanks to @kindermax (#426)!