-
Notifications
You must be signed in to change notification settings - Fork 23
/
jobs.py
27 lines (20 loc) · 937 Bytes
/
jobs.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
import time
import schedule
from src.etls.boe.load import today as boe_today
from src.etls.bopz.load import today as bopz_today
from src.etls.bocm.load import today as bocm_today
from src.etls.bopv.load import today as bopv_today
from src.etls.boja.load import today as boja_today
from src.etls.boa.load import today as boa_today
from src.initialize import initialize_app
INIT_OBJECTS = initialize_app()
schedule.every().day.at("11:00").do(boe_today, init_objects=INIT_OBJECTS)
schedule.every().day.at("11:05").do(bopz_today, init_objects=INIT_OBJECTS)
schedule.every().day.at("11:10").do(bocm_today, init_objects=INIT_OBJECTS)
schedule.every().day.at("11:15").do(bopv_today, init_objects=INIT_OBJECTS)
schedule.every().day.at("11:20").do(boja_today, init_objects=INIT_OBJECTS)
schedule.every().day.at("11:25").do(boa_today, init_objects=INIT_OBJECTS)
# TODO: monthly jobs
while True:
schedule.run_pending()
time.sleep(1)