diff --git a/ckanext/harvest/queue.py b/ckanext/harvest/queue.py
index 65118c7..71e295e 100644
--- a/ckanext/harvest/queue.py
+++ b/ckanext/harvest/queue.py
@@ -216,7 +216,7 @@ def fetch_and_import_stages(harvester, obj):
         obj.state = "ERROR"
         obj.save()
     if obj.report_status:
-        continue
+        return
     if obj.state == 'ERROR':
         obj.report_status = 'errored'
     elif obj.current == False: