Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Add copy buttons to all
 blocks\n(function() {\n function addCopyButtons() {\n document.querySelectorAll('pre code').forEach(function(codeBlock) {\n if (codeBlock.parentElement.hasAttribute('data-copy-added')) return;\n codeBlock.parentElement.setAttribute('data-copy-added', 'true');\n \n var btn = document.createElement('button');\n btn.textContent = 'Copy';\n btn.style.cssText = 'position:absolute;top:4px;right:4px;padding:2px 8px;font-size:11px;background:#4ecdc4;border:none;border-radius:4px;color:#1a1a2e;cursor:pointer;opacity:0.7;transition:opacity 0.2s;';\n btn.onmouseover = function() { this.style.opacity = '1'; };\n btn.onmouseout = function() { this.style.opacity = '0.7'; };\n btn.onclick = function() {\n navigator.clipboard.writeText(codeBlock.textContent).then(function() {\n btn.textContent = 'Copied!';\n setTimeout(function() { btn.textContent = 'Copy'; }, 1500);\n });\n };\n codeBlock.parentElement.style.position = 'relative';\n codeBlock.parentElement.appendChild(btn);\n });\n }\n \n addCopyButtons();\n \n // Re-run on dynamic content\n var observer = new MutationObserver(addCopyButtons);\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "Add Copy Buttons to Code Blocks");
}
} catch(__e) { console.warn('[Userscript:Add Copy Buttons to Code Blocks]', __e); }
})();
(function(){
try {
var __m = "github.com";
var __re = new RegExp('^' + "github\\.com" + '
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Force GitHub README to respect dark mode\n(function() {\n var style = document.createElement('style');\n style.textContent = '\n .markdown-body {\n color-scheme: dark light;\n }\n .markdown-body pre { background: #161b22 !important; }\n .markdown-body code { background: rgba(110, 118, 129, 0.4) !important; }\n .markdown-body table th, .markdown-body table td { border-color: #30363d !important; }\n .markdown-body img { background: #0d1117; }\n .markdown-body blockquote { border-left-color: #8b949e; }\n .markdown-body hr { border-color: #30363d; }\n ';\n document.head.appendChild(style);\n})();", "GitHub Dark Mode README Fix"); } } catch(__e) { console.warn('[Userscript:GitHub Dark Mode README Fix]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + '
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Highlight search terms from Google/DuckDuckGo/Bing referrer\n(function() {\n var ref = document.referrer;\n var terms = [];\n \n if (ref.includes('google.com') || ref.includes('duckduckgo.com') || ref.includes('bing.com')) {\n var url = new URL(ref);\n var q = url.searchParams.get('q') || url.searchParams.get('p');\n if (q) {\n terms = q.split(/\\s+/).filter(function(t) { return t.length > 2; });\n }\n }\n \n if (terms.length === 0) return;\n \n var style = document.createElement('style');\n style.textContent = '.userscript-highlight { background: #fbbf24; color: #1a1a2e; padding: 1px 3px; border-radius: 2px; }';\n document.head.appendChild(style);\n \n function highlight(node) {\n if (node.nodeType === 3) { // text node\n var text = node.textContent;\n var found = false;\n terms.forEach(function(term) {\n var regex = new RegExp('(' + term.replace(/[.*+?^${}()|[\\]\\\\]/g, '\\\\') + ')', 'gi');\n if (regex.test(text)) {\n found = true;\n var frag = document.createDocumentFragment();\n var parts = text.split(regex);\n parts.forEach(function(part, i) {\n if (i % 2 === 0) {\n frag.appendChild(document.createTextNode(part));\n } else {\n var span = document.createElement('span');\n span.className = 'userscript-highlight';\n span.textContent = part;\n frag.appendChild(span);\n }\n });\n node.parentNode.replaceChild(frag, node);\n }\n });\n } else if (node.nodeType === 1 && node.childNodes) { // element\n var skipTags = ['SCRIPT', 'STYLE', 'NOSCRIPT', 'TEXTAREA', 'INPUT', 'SELECT'];\n if (!skipTags.includes(node.tagName)) {\n Array.from(node.childNodes).forEach(highlight);\n }\n }\n }\n \n highlight(document.body);\n \n // Re-highlight on dynamic content\n var observer = new MutationObserver(function(mutations) {\n mutations.forEach(function(m) {\n m.addedNodes.forEach(function(node) {\n if (node.nodeType === 1 || node.nodeType === 3) highlight(node);\n });\n });\n });\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "Highlight Search Terms"); } } catch(__e) { console.warn('[Userscript:Highlight Search Terms]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + '
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Strip utm_, fbclid, gclid, etc. from all links on page\n(function() {\n var trackingParams = ['utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content',\n 'fbclid', 'gclid', 'dclid', 'msclkid', 'yclid',\n 'ref', 'ref_src', 'source', 'medium', 'campaign'];\n \n function cleanUrl(url) {\n try {\n var u = new URL(url, window.location.origin);\n var changed = false;\n trackingParams.forEach(function(p) {\n if (u.searchParams.has(p)) {\n u.searchParams.delete(p);\n changed = true;\n }\n });\n return changed ? u.toString() : url;\n } catch (e) {\n return url;\n }\n }\n \n function cleanLinks() {\n document.querySelectorAll('a[href]').forEach(function(a) {\n var clean = cleanUrl(a.href);\n if (clean !== a.href) a.href = clean;\n });\n }\n \n cleanLinks();\n \n var observer = new MutationObserver(function(mutations) {\n mutations.forEach(function(m) {\n m.addedNodes.forEach(function(node) {\n if (node.nodeType === 1) {\n if (node.tagName === 'A') cleanLinks();\n node.querySelectorAll('a[href]').forEach(function(a) {\n var clean = cleanUrl(a.href);\n if (clean !== a.href) a.href = clean;\n });\n }\n });\n });\n });\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "Remove Tracking Parameters from Links"); } } catch(__e) { console.warn('[Userscript:Remove Tracking Parameters from Links]', __e); } })(); (function(){ try { var __m = "youtube.com"; var __re = new RegExp('^' + "youtube\\.com" + '
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Auto-enable theater mode on YouTube\n(function() {\n function tryTheater() {\n var btn = document.querySelector('button[aria-label=\"Theater mode\"], ytd-player #player button[title=\"Theater mode\"]');\n if (btn && !btn.classList.contains('activated')) {\n btn.click();\n }\n }\n \n // Try immediately\n tryTheater();\n \n // Try after navigation (SPA)\n var lastUrl = location.href;\n setInterval(function() {\n if (location.href !== lastUrl) {\n lastUrl = location.href;\n setTimeout(tryTheater, 500);\n }\n }, 1000);\n \n // Also try on player load\n var observer = new MutationObserver(tryTheater);\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "YouTube Theater Mode Default"); } } catch(__e) { console.warn('[Userscript:YouTube Theater Mode Default]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + '
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Remove or un-stick sticky/fixed headers that block content\n(function() {\n function unstick() {\n document.querySelectorAll('header, nav, [role=\"banner\"], .header, .navbar, .sticky, .fixed-top, [style*=\"position: fixed\"], [style*=\"position:sticky\"]').forEach(function(el) {\n if (el.style.position === 'fixed' || el.style.position === 'sticky' || \n getComputedStyle(el).position === 'fixed' || getComputedStyle(el).position === 'sticky') {\n el.style.position = 'static';\n el.style.top = 'auto';\n el.style.zIndex = 'auto';\n }\n });\n }\n \n unstick();\n \n var observer = new MutationObserver(unstick);\n observer.observe(document.body, { childList: true, subtree: true, attributes: true, attributeFilter: ['style', 'class'] });\n})();", "Kill Sticky Headers"); } } catch(__e) { console.warn('[Userscript:Kill Sticky Headers]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + '
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Universal Dark Mode - works on any site\n(function() {\n var enabled = true;\n \n function applyDarkMode() {\n if (!enabled) return;\n \n // Create style element if it doesn't exist\n var style = document.getElementById('universal-dark-mode-style');\n if (!style) {\n style = document.createElement('style');\n style.id = 'universal-dark-mode-style';\n document.head.appendChild(style);\n }\n \n // Dark mode CSS - inverts colors but preserves images/video\n style.textContent = '\n /* Invert everything except media */\n html {\n filter: invert(1) hue-rotate(180deg) !important;\n background: #1a1a2e !important;\n }\n \n /* Restore images, videos, iframes, canvas */\n img, video, iframe, canvas, svg, picture, [style*=\"background-image\"] {\n filter: invert(1) hue-rotate(180deg) !important;\n }\n \n /* Preserve specific elements that should not be inverted */\n .no-dark-mode, .no-dark-mode *,\n [data-theme=\"light\"], [data-theme=\"light\"],\n .ace_editor, .ace_editor *,\n .CodeMirror, .CodeMirror *,\n .monaco-editor, .monaco-editor *,\n .markdown-body pre, .markdown-body pre *,\n .highlight, .highlight *,\n pre code, pre code * {\n filter: none !important;\n }\n \n /* Fix common UI elements */\n .modal, .popup, .dropdown-menu, .tooltip, .popover {\n filter: invert(1) hue-rotate(180deg) !important;\n background: #2d2d44 !important;\n border-color: #444 !important;\n }\n \n /* Scrollbars */\n ::-webkit-scrollbar { background: #1a1a2e !important; }\n ::-webkit-scrollbar-thumb { background: #444 !important; }\n ::-webkit-scrollbar-thumb:hover { background: #555 !important; }\n \n /* Selection */\n ::selection { background: #4ecdc4 !important; color: #1a1a2e !important; }\n ::-moz-selection { background: #4ecdc4 !important; color: #1a1a2e !important; }\n ';\n }\n \n function removeDarkMode() {\n var style = document.getElementById('universal-dark-mode-style');\n if (style) style.remove();\n }\n \n // Toggle with Alt+Shift+D\n document.addEventListener('keydown', function(e) {\n if (e.altKey && e.shiftKey && e.key === 'D') {\n e.preventDefault();\n enabled = !enabled;\n if (enabled) {\n applyDarkMode();\n console.log('[Universal Dark Mode] Enabled');\n } else {\n removeDarkMode();\n console.log('[Universal Dark Mode] Disabled');\n }\n }\n });\n \n // Apply on load\n applyDarkMode();\n \n // Re-apply on dynamic content\n var observer = new MutationObserver(function(mutations) {\n if (enabled && !document.getElementById('universal-dark-mode-style')) {\n applyDarkMode();\n }\n });\n observer.observe(document.head, { childList: true });\n \n console.log('[Universal Dark Mode] Loaded - Press Alt+Shift+D to toggle');\n})();", "Universal Dark Mode"); } } catch(__e) { console.warn('[Userscript:Universal Dark Mode]', __e); } })(); })();
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 18 additions & 0 deletions CHANGELOG.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,6 +17,24 @@
under the License.
-->

# v3.0.2

## Major changes:

- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))

## Bug Fixes

- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))

# v3.0.0

This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.
Expand Down
3 changes: 1 addition & 2 deletions airflow_client/client/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -14,7 +14,7 @@
""" # noqa: E501


__version__ = "3.0.0"
__version__ = "3.0.2"

# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
Expand DownExpand Up@@ -68,7 +68,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
17 changes: 0 additions & 17 deletions airflow_client/client/api/dag_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -2097,7 +2097,6 @@ def patch_dags(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2135,8 +2134,6 @@ def patch_dags(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2170,7 +2167,6 @@ def patch_dags(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
Expand DownExpand Up@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
:type exclude_stale: bool
:param paused:
:type paused: bool
:param last_dag_run_state:
:type last_dag_run_state: DagRunState
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
Expand DownExpand Up@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
dag_id_pattern=dag_id_pattern,
exclude_stale=exclude_stale,
paused=paused,
last_dag_run_state=last_dag_run_state,
_request_auth=_request_auth,
_content_type=_content_type,
_headers=_headers,
Expand DownExpand Up@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
dag_id_pattern,
exclude_stale,
paused,
last_dag_run_state,
_request_auth,
_content_type,
_headers,
Expand DownExpand Up@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(

_query_params.append(('paused', paused))

if last_dag_run_state is not None:

_query_params.append(('last_dag_run_state', last_dag_run_state.value))

# process the header parameters
# process the form parameters
# process the body parameter
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api/task_instance_api.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -726,7 +726,7 @@ def _get_log_serialize(
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
'text/plain'
'application/x-ndjson'
]
)

Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/api_client.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -90,7 +90,7 @@ def __init__(
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
self.client_side_validation = configuration.client_side_validation

def __enter__(self):
Expand Down
2 changes: 1 addition & 1 deletion airflow_client/client/configuration.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
"SDK Package Version: 3.0.0".\
"SDK Package Version: 3.0.2".\
format(env=sys.platform, pyversion=sys.version)

def get_host_settings(self) -> List[HostSetting]:
Expand Down
1 change: 0 additions & 1 deletion airflow_client/client/models/__init__.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -26,7 +26,6 @@
from airflow_client.client.models.backfill_post_body import BackfillPostBody
from airflow_client.client.models.backfill_response import BackfillResponse
from airflow_client.client.models.base_info_response import BaseInfoResponse
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.bulk_action_response import BulkActionResponse
Expand Down
38 changes: 0 additions & 38 deletions airflow_client/client/models/bulk_action.py

This file was deleted.

Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.connection_body import ConnectionBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
"""
BulkCreateActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_create_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.pool_body import PoolBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
"""
BulkCreateActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[PoolBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
from airflow_client.client.models.variable_body import VariableBody
from typing import Optional, Set
Expand All@@ -29,11 +28,18 @@ class BulkCreateActionVariableBody(BaseModel):
"""
BulkCreateActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_existence: Optional[BulkActionOnExistence] = None
entities: List[VariableBody] = Field(description="A list of entities to be created.")
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['create']):
raise ValueError("must be one of enum values ('create')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionConnectionBody(BaseModel):
"""
BulkDeleteActionConnectionBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
12 changes: 9 additions & 3 deletions airflow_client/client/models/bulk_delete_action_pool_body.py
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionPoolBody(BaseModel):
"""
BulkDeleteActionPoolBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Original file line numberDiff line numberDiff line change
Expand Up@@ -17,9 +17,8 @@
import re # noqa: F401
import json

from pydantic import BaseModel, ConfigDict, Field, StrictStr
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.bulk_action import BulkAction
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
from typing import Optional, Set
from typing_extensions import Self
Expand All@@ -28,11 +27,18 @@ class BulkDeleteActionVariableBody(BaseModel):
"""
BulkDeleteActionVariableBody
""" # noqa: E501
action: BulkAction = Field(description="The action to be performed on the entities.")
action: StrictStr = Field(description="The action to be performed on the entities.")
action_on_non_existence: Optional[BulkActionNotOnExistence] = None
entities: List[StrictStr] = Field(description="A list of entity id/key to be deleted.")
__properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"]

@field_validator('action')
def action_validate_enum(cls, value):
"""Validates the enum"""
if value not in set(['delete']):
raise ValueError("must be one of enum values ('delete')")
return value

model_config = ConfigDict(
populate_by_name=True,
validate_assignment=True,
Expand Down
Loading