ephraimbuddy commented on code in PR #73322:
URL: https://github.com/apache/airflow/pull/73322#discussion_r4108452179
##########
airflow-ctl/src/airflowctl/api/datamodels/generated.py:
##########
@@ -2155,6 +2222,93 @@ class DagStatsResponse(BaseModel):
stats: Annotated[list[DagStatsStateResponse], Field(title="Stats")]
+class DagVersionDiffChangeResponse(BaseModel):
+ """
+ One structural difference between two stored Dag versions.
+ """
+
+ path: Annotated[str, Field(title="Path")]
+ operation: DagVersionDiffOperation
+ category: DagVersionDiffCategory
+ impact: DagVersionDiffImpact
+ occurrence_count: Annotated[
+ int,
+ Field(
+ description="How many underlying changes this record stands for.
Always 1 when values are disclosed, since each change is then its own record; a
redacted record merges every change sharing its path and operation.",
+ title="Occurrence Count",
+ ),
+ ]
+ before_digest: Annotated[
+ str | None,
+ Field(
+ description="SHA-256 over the canonical JSON of `before_value`.
Present only when values are disclosed, and null when the change has no before
side.",
+ title="Before Digest",
+ ),
+ ] = None
+ after_digest: Annotated[
+ str | None,
+ Field(
+ description="SHA-256 over the canonical JSON of `after_value`.
Present only when values are disclosed, and null when the change has no after
side.",
+ title="After Digest",
+ ),
+ ] = None
+ before_value: Annotated[
+ Any | None,
+ Field(
+ description="The value this path held in the base version. Present
only when values are disclosed, and omitted entirely when the change has no
before side — which is how an absent side is told apart from a stored null.",
+ title="Before Value",
+ ),
+ ] = None
+ after_value: Annotated[
+ Any | None,
+ Field(
+ description="The value this path holds in the target version.
Present only when values are disclosed, and omitted entirely when the change
has no after side — which is how an absent side is told apart from a stored
null.",
+ title="After Value",
+ ),
+ ] = None
+
+
+class DagVersionDiffResponse(BaseModel):
+ """
+ Observed-state difference between two stored Dag versions.
+ """
+
+ diff_schema_version: Annotated[
+ int,
+ Field(
+ description="Wire format of this payload. Incremented when its
shape changes.",
+ title="Diff Schema Version",
+ ),
+ ]
+ base_version_number: Annotated[int, Field(title="Base Version Number")]
+ target_version_number: Annotated[int, Field(title="Target Version Number")]
+ serialized_dag_schema_versions: DagVersionDiffSchemaVersions
Review Comment:
Fixed
--
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]
