@@ -81,6 +81,8 @@ def process_initializer(app, hostname):
for name, task in items(app.tasks):
task.__trace__ = build_tracer(name, task, app.loader, hostname,
app=app)
+ from celery.worker import state as worker_state
+ worker_state.reset_state()
signals.worker_process_init.send(sender=None)
@@ -63,6 +63,14 @@ should_stop = None
should_terminate = None
+def reset_state():
+ reserved_requests.clear()
+ active_requests.clear()
+ total_count.clear()
+ all_total_count[:] = [0]
+ revoked.clear()
+
def maybe_shutdown():
if should_stop is not None and should_stop is not False:
raise WorkerShutdown(should_stop)