Skip to content

Commit f32940b

Browse files
committed
update description
1 parent 6e8eedf commit f32940b

3 files changed

Lines changed: 2 additions & 13 deletions

File tree

providers/dq/docs/assets.rst

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -63,11 +63,4 @@ Put the gate first in a Dag scheduled by the asset, and chain everything else af
6363
gate >> process_orders()
6464
6565
``min_score`` must be between ``0`` and ``1``; the check considers only the *most recent*
66-
triggering event for the asset when a run was triggered by several. A missing summary or a
67-
score below the threshold produces a warning-level log entry and a skipped run rather than a
68-
failed one -- a bad batch of upstream data is an expected, recoverable condition, not a bug in
69-
the consumer Dag.
70-
71-
The two Dags are wired together only through the asset -- the producer above and the consumer
72-
here have no direct dependency on each other; either can be redeployed, renamed, or replaced
73-
independently as long as the asset name and its ``airflow.dq`` config stay the same.
66+
triggering event for the asset when a run was triggered by several.

providers/dq/src/airflow/providers/dq/rules/rule.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,6 @@ class Condition(BaseModel):
4747
``greater_than``, ``less_than``, ``geq_to``, ``leq_to``, plus a percentage
4848
``tolerance`` that widens ``equal_to`` into a range.
4949
50-
Invalid input (e.g. no comparison set, or an unknown key) raises pydantic's own
51-
:class:`~pydantic.ValidationError` -- there's no provider-specific wrapper around it.
5250
"""
5351

5452
model_config = ConfigDict(frozen=True, extra="forbid")
@@ -181,8 +179,6 @@ def _validate(self) -> DQRule:
181179
@property
182180
def rule_uid(self) -> str:
183181
"""Stable identity across runs: survives severity/dimension tweaks and Dag refactors."""
184-
# _validate() always fills in condition before returning; cast tells the type
185-
# checker what the validator already guarantees at runtime.
186182
condition = cast("Condition", self.condition)
187183
identity = {
188184
"name": self.previous_name or self.name,

providers/dq/src/airflow/providers/dq/skills/dq-rule-authoring/references/ruleset.schema.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
"$defs": {
33
"Condition": {
44
"additionalProperties": false,
5-
"description": "Pass/fail condition evaluated against a rule's observed value.\n\nUses the same grammar as the ``common.sql`` check operators: ``equal_to``,\n``greater_than``, ``less_than``, ``geq_to``, ``leq_to``, plus a percentage\n``tolerance`` that widens ``equal_to`` into a range.\n\nInvalid input (e.g. no comparison set, or an unknown key) raises pydantic's own\n:class:`~pydantic.ValidationError` -- there's no provider-specific wrapper around it.",
5+
"description": "Pass/fail condition evaluated against a rule's observed value.\n\nUses the same grammar as the ``common.sql`` check operators: ``equal_to``,\n``greater_than``, ``less_than``, ``geq_to``, ``leq_to``, plus a percentage\n``tolerance`` that widens ``equal_to`` into a range.",
66
"properties": {
77
"equal_to": {
88
"anyOf": [

0 commit comments

Comments
 (0)