Serge Smertin
06/24/2021, 7:35 PM@solid
def just_run(_):
<http://_.log.info|_.log.info>(f'Just run....')
@pipeline(mode_defs=[ModeDefinition(
resource_defs={'io_manager': fs_io_manager},
executor_defs=[multiprocess_executor])])
def dummy():
just_run()
@daily_schedule(
pipeline_name=dummy.__name__,
start_date=datetime.datetime(2021, 6, 24),
execution_time=datetime.time(21, 32),
should_execute=lambda _: True,
# should_execute=lambda _: datetime.today().weekday() < 5,
execution_timezone='Europe/Amsterdam')
def daily(date):
print(f'Daily stuff... {date}')
return {}
latest tick is always skipped and daemon is telling
2021-06-24 21:32:29 - SchedulerDaemon - INFO - Evaluating schedule `daily` at 2021-06-24 21:32:00+0200
2021-06-24 21:32:29 - SchedulerDaemon - INFO - No run requests returned for daily, skipping
what is wrong?...daniel
06/24/2021, 8:31 PMSerge Smertin
06/24/2021, 9:28 PM