Anyelin Calderon
12/24/2021, 12:24 PMAnna Geller
Anyelin Calderon
12/24/2021, 2:22 PMAnyelin Calderon
12/24/2021, 2:23 PM@task
def etl():
print("*********** Hola Mundo 2 *****************")
dt = pendulum.today(tz="America/buenos_aires").subtract(days=1) #Fecha de hoy menos 1 dia
cron_schedule = CronSchedule("00 11 * * *", start_date=dt)
#For more information on scheduling see the section Cron Time in the Cron chapter
with Flow('ETL',schedule = cron_schedule, executor=LocalDaskExecutor(num_workers=2) ) as flow:
etl = etl()
# -- Llamado del flujo
flow.run_config = LocalRun()
flow.run()
Kevin Kho
Anyelin Calderon
01/03/2022, 1:46 PMAnna Geller