[Bugfix] Fix KeyError after exception

• After a consumer of PipelinedExecutor.run_tasks throws an exception, it’s possible that results from the old run still end up in the response queue. Log them as a warning and ignore (#1308)