| # coding: utf-8 |
| |
| # flake8: noqa |
| |
| """ |
| Airflow API |
| |
| Airflow API. All endpoints located under ``/api/v2`` can be used safely, are stable and backward compatible. Endpoints located under ``/ui`` are dedicated to the UI and are subject to breaking change depending on the need of the frontend. Users should not rely on those but use the public ones instead. |
| |
| The version of the OpenAPI document: 2 |
| Generated by OpenAPI Generator (https://openapi-generator.tech) |
| |
| Do not edit the class manually. |
| """ # noqa: E501 |
| |
| |
| __version__ = "3.1.0" |
| |
| # import apis into sdk package |
| from airflow_client.client.api.asset_api import AssetApi |
| from airflow_client.client.api.backfill_api import BackfillApi |
| from airflow_client.client.api.config_api import ConfigApi |
| from airflow_client.client.api.connection_api import ConnectionApi |
| from airflow_client.client.api.dag_api import DAGApi |
| from airflow_client.client.api.dag_parsing_api import DAGParsingApi |
| from airflow_client.client.api.dag_report_api import DagReportApi |
| from airflow_client.client.api.dag_run_api import DagRunApi |
| from airflow_client.client.api.dag_source_api import DagSourceApi |
| from airflow_client.client.api.dag_stats_api import DagStatsApi |
| from airflow_client.client.api.dag_version_api import DagVersionApi |
| from airflow_client.client.api.dag_warning_api import DagWarningApi |
| from airflow_client.client.api.event_log_api import EventLogApi |
| from airflow_client.client.api.extra_links_api import ExtraLinksApi |
| from airflow_client.client.api.import_error_api import ImportErrorApi |
| from airflow_client.client.api.job_api import JobApi |
| from airflow_client.client.api.login_api import LoginApi |
| from airflow_client.client.api.monitor_api import MonitorApi |
| from airflow_client.client.api.plugin_api import PluginApi |
| from airflow_client.client.api.pool_api import PoolApi |
| from airflow_client.client.api.provider_api import ProviderApi |
| from airflow_client.client.api.task_api import TaskApi |
| from airflow_client.client.api.task_instance_api import TaskInstanceApi |
| from airflow_client.client.api.variable_api import VariableApi |
| from airflow_client.client.api.version_api import VersionApi |
| from airflow_client.client.api.x_com_api import XComApi |
| from airflow_client.client.api.experimental_api import ExperimentalApi |
| |
| # import ApiClient |
| from airflow_client.client.api_response import ApiResponse |
| from airflow_client.client.api_client import ApiClient |
| from airflow_client.client.configuration import Configuration |
| from airflow_client.client.exceptions import OpenApiException |
| from airflow_client.client.exceptions import ApiTypeError |
| from airflow_client.client.exceptions import ApiValueError |
| from airflow_client.client.exceptions import ApiKeyError |
| from airflow_client.client.exceptions import ApiAttributeError |
| from airflow_client.client.exceptions import ApiException |
| |
| # import models into sdk package |
| from airflow_client.client.models.app_builder_menu_item_response import AppBuilderMenuItemResponse |
| from airflow_client.client.models.app_builder_view_response import AppBuilderViewResponse |
| from airflow_client.client.models.asset_alias_collection_response import AssetAliasCollectionResponse |
| from airflow_client.client.models.asset_alias_response import AssetAliasResponse |
| from airflow_client.client.models.asset_collection_response import AssetCollectionResponse |
| from airflow_client.client.models.asset_event_collection_response import AssetEventCollectionResponse |
| from airflow_client.client.models.asset_event_response import AssetEventResponse |
| from airflow_client.client.models.asset_response import AssetResponse |
| from airflow_client.client.models.backfill_collection_response import BackfillCollectionResponse |
| 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_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 |
| from airflow_client.client.models.bulk_body_bulk_task_instance_body import BulkBodyBulkTaskInstanceBody |
| from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner |
| from airflow_client.client.models.bulk_body_connection_body import BulkBodyConnectionBody |
| from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner |
| from airflow_client.client.models.bulk_body_pool_body import BulkBodyPoolBody |
| from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner |
| from airflow_client.client.models.bulk_body_variable_body import BulkBodyVariableBody |
| from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner |
| from airflow_client.client.models.bulk_create_action_bulk_task_instance_body import BulkCreateActionBulkTaskInstanceBody |
| from airflow_client.client.models.bulk_create_action_connection_body import BulkCreateActionConnectionBody |
| from airflow_client.client.models.bulk_create_action_pool_body import BulkCreateActionPoolBody |
| from airflow_client.client.models.bulk_create_action_variable_body import BulkCreateActionVariableBody |
| from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body import BulkDeleteActionBulkTaskInstanceBody |
| from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner |
| from airflow_client.client.models.bulk_delete_action_connection_body import BulkDeleteActionConnectionBody |
| from airflow_client.client.models.bulk_delete_action_pool_body import BulkDeleteActionPoolBody |
| from airflow_client.client.models.bulk_delete_action_variable_body import BulkDeleteActionVariableBody |
| from airflow_client.client.models.bulk_response import BulkResponse |
| from airflow_client.client.models.bulk_task_instance_body import BulkTaskInstanceBody |
| from airflow_client.client.models.bulk_update_action_bulk_task_instance_body import BulkUpdateActionBulkTaskInstanceBody |
| from airflow_client.client.models.bulk_update_action_connection_body import BulkUpdateActionConnectionBody |
| from airflow_client.client.models.bulk_update_action_pool_body import BulkUpdateActionPoolBody |
| from airflow_client.client.models.bulk_update_action_variable_body import BulkUpdateActionVariableBody |
| from airflow_client.client.models.clear_task_instances_body import ClearTaskInstancesBody |
| from airflow_client.client.models.clear_task_instances_body_task_ids_inner import ClearTaskInstancesBodyTaskIdsInner |
| from airflow_client.client.models.config import Config |
| from airflow_client.client.models.config_option import ConfigOption |
| from airflow_client.client.models.config_section import ConfigSection |
| from airflow_client.client.models.connection_body import ConnectionBody |
| from airflow_client.client.models.connection_collection_response import ConnectionCollectionResponse |
| from airflow_client.client.models.connection_response import ConnectionResponse |
| from airflow_client.client.models.connection_test_response import ConnectionTestResponse |
| from airflow_client.client.models.content import Content |
| from airflow_client.client.models.create_asset_events_body import CreateAssetEventsBody |
| from airflow_client.client.models.dag_collection_response import DAGCollectionResponse |
| from airflow_client.client.models.dag_details_response import DAGDetailsResponse |
| from airflow_client.client.models.dag_patch_body import DAGPatchBody |
| from airflow_client.client.models.dag_response import DAGResponse |
| from airflow_client.client.models.dag_run_clear_body import DAGRunClearBody |
| from airflow_client.client.models.dag_run_collection_response import DAGRunCollectionResponse |
| from airflow_client.client.models.dag_run_patch_body import DAGRunPatchBody |
| from airflow_client.client.models.dag_run_patch_states import DAGRunPatchStates |
| from airflow_client.client.models.dag_run_response import DAGRunResponse |
| from airflow_client.client.models.dag_runs_batch_body import DAGRunsBatchBody |
| from airflow_client.client.models.dag_source_response import DAGSourceResponse |
| from airflow_client.client.models.dag_tag_collection_response import DAGTagCollectionResponse |
| from airflow_client.client.models.dag_version_collection_response import DAGVersionCollectionResponse |
| from airflow_client.client.models.dag_warning_collection_response import DAGWarningCollectionResponse |
| from airflow_client.client.models.dag_warning_response import DAGWarningResponse |
| from airflow_client.client.models.dag_processor_info_response import DagProcessorInfoResponse |
| from airflow_client.client.models.dag_run_asset_reference import DagRunAssetReference |
| from airflow_client.client.models.dag_run_state import DagRunState |
| from airflow_client.client.models.dag_run_triggered_by_type import DagRunTriggeredByType |
| from airflow_client.client.models.dag_run_type import DagRunType |
| from airflow_client.client.models.dag_schedule_asset_reference import DagScheduleAssetReference |
| from airflow_client.client.models.dag_stats_collection_response import DagStatsCollectionResponse |
| from airflow_client.client.models.dag_stats_response import DagStatsResponse |
| from airflow_client.client.models.dag_stats_state_response import DagStatsStateResponse |
| from airflow_client.client.models.dag_tag_response import DagTagResponse |
| from airflow_client.client.models.dag_version_response import DagVersionResponse |
| from airflow_client.client.models.dag_warning_type import DagWarningType |
| from airflow_client.client.models.detail import Detail |
| from airflow_client.client.models.dry_run_backfill_collection_response import DryRunBackfillCollectionResponse |
| from airflow_client.client.models.dry_run_backfill_response import DryRunBackfillResponse |
| from airflow_client.client.models.event_log_collection_response import EventLogCollectionResponse |
| from airflow_client.client.models.event_log_response import EventLogResponse |
| from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse |
| from airflow_client.client.models.external_view_response import ExternalViewResponse |
| from airflow_client.client.models.extra_link_collection_response import ExtraLinkCollectionResponse |
| from airflow_client.client.models.fast_api_app_response import FastAPIAppResponse |
| from airflow_client.client.models.fast_api_root_middleware_response import FastAPIRootMiddlewareResponse |
| from airflow_client.client.models.hitl_detail import HITLDetail |
| from airflow_client.client.models.hitl_detail_collection import HITLDetailCollection |
| from airflow_client.client.models.hitl_detail_response import HITLDetailResponse |
| from airflow_client.client.models.hitl_user import HITLUser |
| from airflow_client.client.models.http_exception_response import HTTPExceptionResponse |
| from airflow_client.client.models.http_validation_error import HTTPValidationError |
| from airflow_client.client.models.health_info_response import HealthInfoResponse |
| from airflow_client.client.models.import_error_collection_response import ImportErrorCollectionResponse |
| from airflow_client.client.models.import_error_response import ImportErrorResponse |
| from airflow_client.client.models.job_collection_response import JobCollectionResponse |
| from airflow_client.client.models.job_response import JobResponse |
| from airflow_client.client.models.last_asset_event_response import LastAssetEventResponse |
| from airflow_client.client.models.patch_task_instance_body import PatchTaskInstanceBody |
| from airflow_client.client.models.plugin_collection_response import PluginCollectionResponse |
| from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse |
| from airflow_client.client.models.plugin_import_error_response import PluginImportErrorResponse |
| from airflow_client.client.models.plugin_response import PluginResponse |
| from airflow_client.client.models.pool_body import PoolBody |
| from airflow_client.client.models.pool_collection_response import PoolCollectionResponse |
| from airflow_client.client.models.pool_patch_body import PoolPatchBody |
| from airflow_client.client.models.pool_response import PoolResponse |
| from airflow_client.client.models.provider_collection_response import ProviderCollectionResponse |
| from airflow_client.client.models.provider_response import ProviderResponse |
| from airflow_client.client.models.queued_event_collection_response import QueuedEventCollectionResponse |
| from airflow_client.client.models.queued_event_response import QueuedEventResponse |
| from airflow_client.client.models.react_app_response import ReactAppResponse |
| from airflow_client.client.models.reprocess_behavior import ReprocessBehavior |
| from airflow_client.client.models.response_clear_dag_run import ResponseClearDagRun |
| from airflow_client.client.models.response_get_xcom_entry import ResponseGetXcomEntry |
| from airflow_client.client.models.scheduler_info_response import SchedulerInfoResponse |
| from airflow_client.client.models.structured_log_message import StructuredLogMessage |
| from airflow_client.client.models.task_collection_response import TaskCollectionResponse |
| from airflow_client.client.models.task_dependency_collection_response import TaskDependencyCollectionResponse |
| from airflow_client.client.models.task_dependency_response import TaskDependencyResponse |
| from airflow_client.client.models.task_inlet_asset_reference import TaskInletAssetReference |
| from airflow_client.client.models.task_instance_collection_response import TaskInstanceCollectionResponse |
| from airflow_client.client.models.task_instance_history_collection_response import TaskInstanceHistoryCollectionResponse |
| from airflow_client.client.models.task_instance_history_response import TaskInstanceHistoryResponse |
| from airflow_client.client.models.task_instance_response import TaskInstanceResponse |
| from airflow_client.client.models.task_instance_state import TaskInstanceState |
| from airflow_client.client.models.task_instances_batch_body import TaskInstancesBatchBody |
| from airflow_client.client.models.task_instances_log_response import TaskInstancesLogResponse |
| from airflow_client.client.models.task_outlet_asset_reference import TaskOutletAssetReference |
| from airflow_client.client.models.task_response import TaskResponse |
| from airflow_client.client.models.time_delta import TimeDelta |
| from airflow_client.client.models.trigger_dag_run_post_body import TriggerDAGRunPostBody |
| from airflow_client.client.models.trigger_response import TriggerResponse |
| from airflow_client.client.models.triggerer_info_response import TriggererInfoResponse |
| from airflow_client.client.models.update_hitl_detail_payload import UpdateHITLDetailPayload |
| from airflow_client.client.models.validation_error import ValidationError |
| from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner |
| from airflow_client.client.models.value import Value |
| from airflow_client.client.models.variable_body import VariableBody |
| from airflow_client.client.models.variable_collection_response import VariableCollectionResponse |
| from airflow_client.client.models.variable_response import VariableResponse |
| from airflow_client.client.models.version_info import VersionInfo |
| from airflow_client.client.models.x_com_collection_response import XComCollectionResponse |
| from airflow_client.client.models.x_com_create_body import XComCreateBody |
| from airflow_client.client.models.x_com_response import XComResponse |
| from airflow_client.client.models.x_com_response_native import XComResponseNative |
| from airflow_client.client.models.x_com_response_string import XComResponseString |
| from airflow_client.client.models.x_com_update_body import XComUpdateBody |