Use subscription fact type, and assign task id in completed_task.js component
python rewarder using queues