I'm attempting to defer to any subclassed naming behavior with this (like the `batcher.MessageProcessor`). I tried doing the append restart_count and it certainly worked for that task, however the restarted tasks were still be inserted along with new tasks from the asyncs that were being executed correctly. If we defer to a subclass' naming behavior then both restarts and fresh instances will dedupe together. So by trying to append the restart count, I _was_ fork bombing the queue :frowning: