Coverage for /home/airflow/.local/lib/python3.12/site-packages/airflow/api_fastapi/core_api/datamodels/ui/assets.py: 100%

1# Licensed to the Apache Software Foundation (ASF) under one 

2# or more contributor license agreements. See the NOTICE file 

3# distributed with this work for additional information 

4# regarding copyright ownership. The ASF licenses this file 

5# to you under the Apache License, Version 2.0 (the 

6# "License"); you may not use this file except in compliance 

7# with the License. You may obtain a copy of the License at 

8# 

9# http://www.apache.org/licenses/LICENSE-2.0 

10# 

11# Unless required by applicable law or agreed to in writing, 

12# software distributed under the License is distributed on an 

13# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 

14# KIND, either express or implied. See the License for the 

15# specific language governing permissions and limitations 

16# under the License. 

17from __future__ import annotations 

18 

19from datetime import datetime 

20 

21from pydantic import Field 

22 

23from airflow.api_fastapi.core_api.base import BaseModel 

24 

25 

26class NextRunAssetEventResponse(BaseModel): 

27 """One asset event in the ``next_run_assets`` payload.""" 

28 

29 id: int 

30 name: str | None 

31 uri: str 

32 last_update: datetime | None = None 

33 received_count: int = 0 

34 required_count: int = 1 

35 received_keys: list[str] = Field(default_factory=list) 

36 required_keys: list[str] = Field(default_factory=list) 

37 is_rollup: bool = False 

38 mapper_error: bool = False 

39 """True when the rollup mapper raised; the asset is not-yet-satisfied and 

40 counts / keys are placeholders. The scheduler holds the Dag run for this 

41 asset — UIs should surface this state rather than treating it as "waiting".""" 

42 asset_inactive: bool = False 

43 """True when the upstream asset has been deactivated (orphaned — no Dag 

44 declares it any more). The scheduler freezes partition evaluation for any 

45 APDR depending on this asset; the UI should surface this state rather 

46 than treating it as "waiting".""" 

47 

48 

49class NextRunAssetsResponse(BaseModel): 

50 """Response for the ``next_run_assets`` endpoint.""" 

51 

52 asset_expression: dict | None = None 

53 events: list[NextRunAssetEventResponse] 

54 pending_partition_count: int | None = None