https://prefect.io
Join Slack
Hi, I am executing a flow at 12:05 to run on 12/24 at 08:00 a.m. but when the schedule is about to r...
# ask-community
a
Hi, I am executing a flow at 12:05 to run on 12/24 at 08:00 a.m. but when the schedule is about to run, the flow starts 1 second before and the schedule changes to the next day 12/24 08hr. I use prefect == 0.15.6
a
You would need to provide a bit more information - do you use Prefect Cloud? Did you register this flow, and if so can you share your flow configuration, especially storage and run config?
a
Hi, my code is simple, only use prefect schedules
@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()
k
You’re just using Prefect Core right?
a
yes, I use Prefect Core
a
Core should not be used for scheduling. You would need to create a free Prefect Cloud account and register your flow to run on schedule (recommended). Or you can deploy Server locally. More on that https://docs.prefect.io/orchestration/getting-started/set-up.html#prefect-cloud-and-server
👍 1
5 Views
Open in Slack
PreviousNext
Powered by

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Powered by