test
parent
036261e2b4
commit
ef21afbcfe
|
@ -4,8 +4,6 @@ from main import read_file_proto_x_stop, r
|
||||||
import logging
|
import logging
|
||||||
import os
|
import os
|
||||||
|
|
||||||
sched = BlockingScheduler()
|
|
||||||
sched.add_job(rutina_principal, 'interval', seconds=int(os.environ.get('INTERVAL'))) #will do the print_t work for every 30 seconds
|
|
||||||
|
|
||||||
def rutina_principal():
|
def rutina_principal():
|
||||||
print(datetime.now(tz))
|
print(datetime.now(tz))
|
||||||
|
@ -41,6 +39,10 @@ def download_file_backend():
|
||||||
return { 'name': nombre_archivo, 'content': response.content }
|
return { 'name': nombre_archivo, 'content': response.content }
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
sched = BlockingScheduler()
|
||||||
|
sched.add_job(rutina_principal, 'interval', seconds=int(os.environ.get('INTERVAL'))) #will do the print_t work for every 30 seconds
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
init_db(db, engine)
|
init_db(db, engine)
|
||||||
sched.start()
|
sched.start()
|
||||||
|
|
Loading…
Reference in New Issue