diff --git a/metaflow/plugins/airflow/airflow_cli.py b/metaflow/plugins/airflow/airflow_cli.py index e9ea4521e28..c938f5e450c 100644 --- a/metaflow/plugins/airflow/airflow_cli.py +++ b/metaflow/plugins/airflow/airflow_cli.py @@ -400,6 +400,16 @@ def _validate_workflow(flow, graph, flow_datastore, metadata, workflow_timeout): ) ) + schedule = flow._flow_decorators.get("schedule") + if not schedule: + return + + schedule = schedule[0] + if schedule.timezone is not None: + raise AirflowException( + "`airflow create` does not support scheduling with `timezone`." + ) + def resolve_dag_name(name): project = current.get("project_name")