Oke ik heb het probleem gevonden. Het was vanwege de time-out van de werknemer.
try:
--my code goes here--
except Exception, ex:
self.error += 1
with open("error.txt", "a") as myfile:
myfile.write('\n%s' % sys.exc_info()[0] + "{}".format(self.url))
pass
Dus volgens mijn code wordt het volgende domein uit de wachtrij gehaald als 200 url('s) van elk domein worden opgehaald. Maar voor sommige domeinen waren er onvoldoende URL's om de voorwaarde te beëindigen (zoals slechts 1 of 2 URL's).
Omdat de code alle uitzonderingen opvangt en wordt toegevoegd aan error.txt
het dossier. Zelfs de rq timeout-uitzondering rq.timeouts.JobTimeoutException
werd gepakt en aan het dossier toegevoegd. Waardoor de werker moet wachten op x
hoeveelheid tijd, die leidt tot beëindiging van de werknemer.