Ask Solem 13 tahun lalu
induk
melakukan
26f4441c29
2 mengubah file dengan 2 tambahan dan 3 penghapusan
  1. 0 1
      celery/apps/worker.py
  2. 2 2
      funtests/benchmarks/bench_worker.py

+ 0 - 1
celery/apps/worker.py

@@ -81,7 +81,6 @@ class Worker(configurated):
             queues=None, include=None, app=None, pidfile=None,
             autoscale=None, **kwargs):
         self.app = app = app_or_default(app)
-        conf = app.conf
         self.setup_defaults(kwargs, namespace="celeryd")
         if not self.concurrency:
             self.concurrency = cpu_count()

+ 2 - 2
funtests/benchmarks/bench_worker.py

@@ -27,8 +27,8 @@ celery.conf.update(BROKER_TRANSPORT="librabbitmq",
                            "exchange": "bench.worker",
                            "routing_key": "bench.worker",
                            "no_ack": True,
-                           #"exchange_durable": False,
-                           #"queue_durable": False,
+                           "exchange_durable": False,
+                           "queue_durable": False,
                            "auto_delete": True,
                         }
                    },