|
|
@@ -40,6 +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
|
|
|
+ )
|
|
|
print("******")
|
|
|
print(worker_name)
|
|
|
qname=worker_name
|
|
|
@@ -154,7 +158,7 @@ def selenium_jared_click3():
|
|
|
driver.quit()
|
|
|
return txt
|
|
|
break
|
|
|
- app.control.shutdown()
|
|
|
+ app.control.broadcast('shutdown')
|
|
|
return '{empty}'
|
|
|
# time.sleep(5)
|
|
|
|
