diff --git a/ckanext/harvest/queue.py b/ckanext/harvest/queue.py
index 37e8c50..fba5e96 100644
--- a/ckanext/harvest/queue.py
+++ b/ckanext/harvest/queue.py
@@ -128,7 +128,7 @@ def gather_callback(channel, method, header, body):
                 channel.basic_ack(method.delivery_tag)
                 model.Session.query(HarvestObject).filter_by(
                     harvest_job_id=job.id
-                ).update(dict(state='ERROR', current=False))
+                ).delete()
                 raise
             finally:
                 job.gather_finished = datetime.datetime.now()