# # schedules/snowflake_schedule.py # from datetime import datetime, timedelta, timezone # from dagster import ScheduleDefinition, ScheduleEvaluationContext, schedule # from src.assets.bot_features import browser_token_job # Import the job directly # @schedule( # job=browser_token_job, # cron_schedule="15 * * * *", # Runs hourly at 15 minutes past # execution_timezone="UTC", # ) # def daily_snowflake_analysis(context: ScheduleEvaluationContext): # """Schedule that runs the Snowflake analysis daily for the previous day.""" # _now = datetime.now(tz=timezone.utc) # end_date = _now.strftime("%Y-%m-%d") # start_date = _now.strftime("%Y-%m-%d") # start_hour = (_now - timedelta(hours=2)).strftime("%H") # end_hour = (_now - timedelta(hours=1)).strftime("%H") # # end_hour = _now.strftime("%H") # return { # "ops": { # "missing_browser_token_features": { # "config": { # "start_date": start_date, # "end_date": end_date, # "start_hour": start_hour, # "end_hour": end_hour, # } # }, # } # } # # Define the schedule using the imported job # browser_token_schedule = ScheduleDefinition( # job=browser_token_job, # cron_schedule="15 * * * *", # Runs hourly at 15 minutes past # name="browser_token_analysis_schedule", # ) # # Export all schedules # schedules = [browser_token_schedule]