|
|
@@ -8,21 +8,29 @@ from selenium.webdriver.support import expected_conditions as EC
|
|
|
from selenium.webdriver.common.keys import Keys
|
|
|
from celery import Celery
|
|
|
import redis
|
|
|
-import json
|
|
|
from celery.schedules import crontab
|
|
|
+import celery
|
|
|
|
|
|
app = Celery('tasks', backend ='redis://172.104.92.245', broker='redis://172.104.92.245')
|
|
|
-
|
|
|
+print(celery.utils.nodenames.gethostname())
|
|
|
#rkey=app.request.delivery_info['routing_key']
|
|
|
|
|
|
-json_str = json.dumps(app, indent=4)
|
|
|
-print(json_str)
|
|
|
-@app.on_after_configure.connect
|
|
|
-def setup_periodic_tasks(sender, **kwargs):
|
|
|
+
|
|
|
+app.conf.beat_schedule = {
|
|
|
+ # Executes every Monday morning at 7:30 a.m.
|
|
|
+ 'add-every-monday-morning': {
|
|
|
+ 'task': 'tasks.selenium_jared_click',
|
|
|
+ 'schedule': crontab(minute='*/2'),
|
|
|
+ 'args': (),
|
|
|
+ },
|
|
|
+}
|
|
|
+
|
|
|
+#@app.on_after_configure.connect
|
|
|
+#def setup_periodic_tasks(sender, **kwargs):
|
|
|
# print(app.request.delivery_info['routing_key'])
|
|
|
# print(json_str)
|
|
|
#sender task.request.hostnam
|
|
|
- sender.add_periodic_task(100.0, selenium_jared_click.s(), name='add every 2 min')
|
|
|
+# sender.add_periodic_task(100.0, selenium_jared_click.s(), name='add every 2 min')
|
|
|
|
|
|
@app.task
|
|
|
def selenium_jared_click():
|
