Implement test_conflator_task_after
test_conflator: implement setup nicely
conflator: store enqueued_time and check what was stored in cache
test_conflator; refactor tests