@schedule(name='heatbeat', pipeline_name='heat_beat_pipeline', cron_schedule='* * * * *') def get_schedules(): return []