Skip to content

Commit

Permalink
added comment on need for start_date
Browse files Browse the repository at this point in the history
  • Loading branch information
valayDave committed Jul 28, 2022
1 parent a3147be commit a3a4950
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions metaflow/plugins/airflow/airflow.py
Expand Up @@ -621,6 +621,9 @@ def _visit(node, workflow, exit_node=None):
default_args=self._create_defaults(),
description=self.description,
schedule_interval=self.schedule,
# `start_date` is a mandatory argument even though the documentation lists it as optional value
# Based on the code, Airflow will throw a `AirflowException` when `start_date` is not provided
# to a DAG : https://github.com/apache/airflow/blob/0527a0b6ce506434a23bc2a6f5ddb11f492fc614/airflow/models/dag.py#L2170
start_date=datetime.now(),
tags=self.tags,
file_path=self._file_path,
Expand Down

0 comments on commit a3a4950

Please sign in to comment.