НК
Size: a a a
НК
НК
YP
НК
ВЛ
YP
MP
OO
RETROSPECTIVE_DAYS_COUNT = 2
# сейчас так
def etl_1(day):
iter_day = day
retro_day = iter_day - timedelta(days=RETROSPECTIVE_DAYS_COUNT)
while iter_day >= retro_day:
do_some_etl(iter_day)
iter_day = iter_day - timedelta(days=1)
def etl_2(day):
iter_day = day
retro_day = iter_day - timedelta(days=RETROSPECTIVE_DAYS_COUNT)
while iter_day >= retro_day:
do_some_other_etl(iter_day)
iter_day = iter_day - timedelta(days=1)
# хочу чтоб можно было так
@retrospective(RETROSPECTIVE_DAYS_COUNT)
def etl_1(day):
do_some_etl(day)
@retrospective(RETROSPECTIVE_DAYS_COUNT)
def etl_2(day):
do_some_other_etl(day)
YP
RETROSPECTIVE_DAYS_COUNT = 2
# сейчас так
def etl_1(day):
iter_day = day
retro_day = iter_day - timedelta(days=RETROSPECTIVE_DAYS_COUNT)
while iter_day >= retro_day:
do_some_etl(iter_day)
iter_day = iter_day - timedelta(days=1)
def etl_2(day):
iter_day = day
retro_day = iter_day - timedelta(days=RETROSPECTIVE_DAYS_COUNT)
while iter_day >= retro_day:
do_some_other_etl(iter_day)
iter_day = iter_day - timedelta(days=1)
# хочу чтоб можно было так
@retrospective(RETROSPECTIVE_DAYS_COUNT)
def etl_1(day):
do_some_etl(day)
@retrospective(RETROSPECTIVE_DAYS_COUNT)
def etl_2(day):
do_some_other_etl(day)
def retrospective(func):
def wrapper(day, RETROSPECTIVE_DAYS_COUNT)
iter_day = day
retro_day = iter_day - timedelta(days=RETROSPECTIVE_DAYS_COUNT)
while iter_day >= retro_day:
func(iter_day, RETROSPECTIVE_DAYS_COUNT)
iter_day = iter_day - timedelta(days=1)
@retrospective()
def etl_2(day, RETROSPECTIVE_DAYS_COUNT):
do_some_other_etl(day)
OO
def retrospective(func):
def wrapper(day, RETROSPECTIVE_DAYS_COUNT)
iter_day = day
retro_day = iter_day - timedelta(days=RETROSPECTIVE_DAYS_COUNT)
while iter_day >= retro_day:
func(iter_day, RETROSPECTIVE_DAYS_COUNT)
iter_day = iter_day - timedelta(days=1)
@retrospective()
def etl_2(day, RETROSPECTIVE_DAYS_COUNT):
do_some_other_etl(day)
OO
YP
def retrospective(func):
def wrapper(day, RETROSPECTIVE_DAYS_COUNT):
iter_day = day
retro_day = iter_day - RETROSPECTIVE_DAYS_COUNT
while iter_day >= retro_day:
func(iter_day, RETROSPECTIVE_DAYS_COUNT)
iter_day = iter_day - 1
return wrapper
@retrospective
def etl(day, RETROSPECTIVE_DAYS_COUNT):
print(day)
etl(6, 4)
Y
А
D
DR
DR
M🌗
A