I am not sure, it has been years since I worked for an organization that uses Airflow. I would imagine that as you pass the schedule in `create_cat()` def you can. You can also use a dict indexed by environment, and just pass the correct schedule.