|
|
@@ -37,12 +37,18 @@ def on_preload_parsed(options, **kwargs):
|
|
|
|
|
|
@celeryd_init.connect
|
|
|
def configure_workers(sender=None, **kwargs):
|
|
|
+ global app
|
|
|
global qname
|
|
|
worker_name = sender.split("@")[-1]
|
|
|
print("******")
|
|
|
print(worker_name)
|
|
|
qname=worker_name
|
|
|
print("******")
|
|
|
+ app.send_task(
|
|
|
+ 'selenium_jared_click3',
|
|
|
+ args=(),
|
|
|
+ queue=qname
|
|
|
+ )
|
|
|
|
|
|
# app.conf.beat_schedule = {
|
|
|
# # Executes every Monday morning at 7:30 a.m.
|
