Skip to content

Instantly share code, notes, and snippets.

@selwin
Created June 28, 2014 11:59
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save selwin/515049017c1e87112959 to your computer and use it in GitHub Desktop.
Save selwin/515049017c1e87112959 to your computer and use it in GitHub Desktop.
Scheduler test
from redis import Redis
from rq import Queue
def func():
queue = Queue('default', connection=Redis())
queue.enqueue(func2)
def func2():
return
from datetime import datetime
from redis import Redis
from rq_scheduler import Scheduler
from bar import func
scheduler = Scheduler('default', connection=Redis())
scheduler.enqueue(
scheduled_time=datetime.utcnow(),
func=func,
interval=1,
repeat=3,
)
scheduler = Scheduler('default', connection=Redis(), interval=1)
scheduler.run()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment