from apscheduler.schedulers.blocking import BlockingScheduler
from rq import Queue
from worker import conn
from run import run_scanFirebase, getLabs, getPhoneNumbers

#creates scheduler object
sched = BlockingScheduler()

#creates connection
q = Queue(connection=conn)

#function that enqueues run function
def scanFirebase():
    q.enqueue(run_scanFirebase)

#adds jobs to queue
sched.add_job(scanFirebase)
sched.add_job(scanFirebase, 'interval', minutes=15)
sched.start()
c2b13af9a16212f4282fa33881982e3007f2abe2
<mask token>


def scanFirebase():
    q.enqueue(run_scanFirebase)


<mask token>

<mask token>


def scanFirebase():
    q.enqueue(run_scanFirebase)


sched.add_job(scanFirebase)
sched.add_job(scanFirebase, 'interval', minutes=15)
sched.start()

<mask token>
sched = BlockingScheduler()
q = Queue(connection=conn)


def scanFirebase():
    q.enqueue(run_scanFirebase)


sched.add_job(scanFirebase)
sched.add_job(scanFirebase, 'interval', minutes=15)
sched.start()

from apscheduler.schedulers.blocking import BlockingScheduler
from rq import Queue
from worker import conn
from run import run_scanFirebase, getLabs, getPhoneNumbers
sched = BlockingScheduler()
q = Queue(connection=conn)


def scanFirebase():
    q.enqueue(run_scanFirebase)


sched.add_job(scanFirebase)
sched.add_job(scanFirebase, 'interval', minutes=15)
sched.start()

from apscheduler.schedulers.blocking import BlockingScheduler
from rq import Queue
from worker import conn
from run import run_scanFirebase, getLabs, getPhoneNumbers

#creates scheduler object
sched = BlockingScheduler()

#creates connection
q = Queue(connection=conn)

#function that enqueues run function
def scanFirebase():
    q.enqueue(run_scanFirebase)

#adds jobs to queue
sched.add_job(scanFirebase)
sched.add_job(scanFirebase, 'interval', minutes=15)
sched.start()