|
|
@@ -40,10 +40,10 @@ def configure_workers(sender=None, **kwargs):
|
|
|
global app
|
|
|
global qname
|
|
|
worker_name = sender.split("@")[-1]
|
|
|
- app.conf.update(
|
|
|
- task_concurrency=1, # Use 4 threads for concurrency
|
|
|
- worker_prefetch_multiplier=1 # Prefetch one task at a time
|
|
|
- )
|
|
|
+# app.conf.update(
|
|
|
+# task_concurrency=1, # Use 4 threads for concurrency
|
|
|
+# worker_prefetch_multiplier=1 # Prefetch one task at a time
|
|
|
+# )
|
|
|
print("******")
|
|
|
print(worker_name)
|
|
|
qname=worker_name
|
|
|
@@ -158,7 +158,7 @@ def selenium_jared_click3():
|
|
|
driver.quit()
|
|
|
return txt
|
|
|
break
|
|
|
- app.control.broadcast('shutdown')
|
|
|
+ celery.control.broadcast('shutdown')
|
|
|
return '{empty}'
|
|
|
# time.sleep(5)
|
|
|
|
