amoghrajesh commented on code in PR #58175:
URL: https://github.com/apache/airflow/pull/58175#discussion_r2811191447
##########
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2026_03_31.py:
##########
@@ -50,3 +54,29 @@ class RemoveUpstreamMapIndexesField(VersionChange):
def add_upstream_map_indexes_field(response: ResponseInfo) -> None: #
type: ignore[misc]
"""Add upstream_map_indexes field with None for older API versions."""
response.body["upstream_map_indexes"] = None
+
+
+class MakeDagRunStartDateNullable(VersionChange):
+ """Make DagRun.start_date field nullable for runs that haven't started
yet."""
+
+ description = __doc__
+
+ instructions_to_migrate_to_previous_version = ()
Review Comment:
To be explicit about the change here
##########
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2026_03_31.py:
##########
@@ -50,3 +54,29 @@ class RemoveUpstreamMapIndexesField(VersionChange):
def add_upstream_map_indexes_field(response: ResponseInfo) -> None: #
type: ignore[misc]
"""Add upstream_map_indexes field with None for older API versions."""
response.body["upstream_map_indexes"] = None
+
+
+class MakeDagRunStartDateNullable(VersionChange):
+ """Make DagRun.start_date field nullable for runs that haven't started
yet."""
+
+ description = __doc__
+
+ instructions_to_migrate_to_previous_version = ()
Review Comment:
```suggestion
instructions_to_migrate_to_previous_version = (
schema(DagRun).field("start_date").had(type=UtcDateTime),
)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
