2,306
edits
Changes
Jump to navigation
Jump to search
Line 26:
Line 26: + + + + + + + + + + + + + + +
no edit summary
== Launch ==
== Launch ==
celery -A {ProjectName} worker -l info --queues=queuename1,queuename2
celery -A {ProjectName} worker -l info --queues=queuename1,queuename2
== Run task at specific time ==
<source lang="Python">import datetime
import celery
@celery.shared_task(bind=True)
def add_tag(task, user_id, tag):
User.objects.filter(id=user_id, tags__ne=tag).update(push__tags=tag)
return True
user_id = '582ee32a5b9c861c87dc297e'
tag = 'new_tag'
started_at = datetime.datetime(2018, 3, 12, tzinfo=datetime.timezone.utc)
add_tag.apply_async((user_id, tag), eta=started_at)</source>