Integration with Dramatiq

[ruslaniv]

Would it be possible to add integration with Dramatiq message queue?

If not, do you guys have any pointers how I can send a correlation ID into a dramatiq task so I can track how each task spawned by a given request is handled?

[sondrelg]

The celery integration passes correlation IDs from the scheduling process to the worker process by using lifecycle hooks built into the framework. Is there an equivalent mechanism for passing data, in dramatiq?