I believe this is all only working from a single queue so its more a metadata issue, perhaps the starting task needs some locking 