|
|
@@ -14,25 +14,27 @@ from celery.signals import celeryd_init
|
|
|
|
|
|
|
|
|
app = Celery('tasks', backend ='redis://172.104.92.245', broker='redis://172.104.92.245')
|
|
|
-
|
|
|
+qname=None
|
|
|
@celeryd_init.connect
|
|
|
def configure_workers(sender=None, **kwargs):
|
|
|
+ global qname
|
|
|
worker_name = sender.split("@")[-1]
|
|
|
#rkey=app.request.delivery_info['routing_key']
|
|
|
print("******")
|
|
|
print(worker_name)
|
|
|
+ qname=worker_name
|
|
|
print("******")
|
|
|
|
|
|
-app.conf.beat_schedule = {
|
|
|
- # Executes every Monday morning at 7:30 a.m.
|
|
|
- 'add-every-monday-morning': {
|
|
|
- 'task': 'cel_seo_click.selenium_jared_click',
|
|
|
-# 'schedule': crontab(minute='*/1'),
|
|
|
- 'schedule': 30.0,
|
|
|
- 'args': (),
|
|
|
- 'options':{'queue': 'xxx'}
|
|
|
- },
|
|
|
-}
|
|
|
+ app.conf.beat_schedule = {
|
|
|
+ # Executes every Monday morning at 7:30 a.m.
|
|
|
+ 'add-every-monday-morning': {
|
|
|
+ 'task': 'cel_seo_click.selenium_jared_click',
|
|
|
+ # 'schedule': crontab(minute='*/1'),
|
|
|
+ 'schedule': 100.0,
|
|
|
+ 'args': (),
|
|
|
+ 'options':{'queue': qname}
|
|
|
+ },
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|
