%global _empty_manifest_terminate_build 0 Name: python-airflow-python-sdk Version: 1.0.1 Release: 1 Summary: Airflow API (Stable) License: MIT URL: https://pypi.org/project/airflow-python-sdk/ Source0: https://mirrors.nju.edu.cn/pypi/web/packages/00/f1/7e034e95b39eb935069d6a342a5c300156595b5c40e02e16cfcd46ee3c1f/airflow-python-sdk-1.0.1.tar.gz BuildArch: noarch Requires: python3-urllib3 Requires: python3-dateutil Requires: python3-nulltype %description *ConfigApi* | [**get_config**](docs/ConfigApi.md#get_config) | **GET** /config | Get current configuration *ConnectionApi* | [**delete_connection**](docs/ConnectionApi.md#delete_connection) | **DELETE** /connections/{connection_id} | Delete a connection *ConnectionApi* | [**get_connection**](docs/ConnectionApi.md#get_connection) | **GET** /connections/{connection_id} | Get a connection *ConnectionApi* | [**get_connections**](docs/ConnectionApi.md#get_connections) | **GET** /connections | List connections *ConnectionApi* | [**patch_connection**](docs/ConnectionApi.md#patch_connection) | **PATCH** /connections/{connection_id} | Update a connection *ConnectionApi* | [**post_connection**](docs/ConnectionApi.md#post_connection) | **POST** /connections | Create a connection *DAGApi* | [**get_dag**](docs/DAGApi.md#get_dag) | **GET** /dags/{dag_id} | Get basic information about a DAG *DAGApi* | [**get_dag_details**](docs/DAGApi.md#get_dag_details) | **GET** /dags/{dag_id}/details | Get a simplified representation of DAG *DAGApi* | [**get_dag_source**](docs/DAGApi.md#get_dag_source) | **GET** /dagSources/{file_token} | Get a source code *DAGApi* | [**get_dags**](docs/DAGApi.md#get_dags) | **GET** /dags | List DAGs *DAGApi* | [**get_task**](docs/DAGApi.md#get_task) | **GET** /dags/{dag_id}/tasks/{task_id} | Get simplified representation of a task *DAGApi* | [**get_tasks**](docs/DAGApi.md#get_tasks) | **GET** /dags/{dag_id}/tasks | Get tasks for DAG *DAGApi* | [**patch_dag**](docs/DAGApi.md#patch_dag) | **PATCH** /dags/{dag_id} | Update a DAG *DAGApi* | [**post_clear_task_instances**](docs/DAGApi.md#post_clear_task_instances) | **POST** /dags/{dag_id}/clearTaskInstances | Clear a set of task instances *DAGApi* | [**post_set_task_instances_state**](docs/DAGApi.md#post_set_task_instances_state) | **POST** /dags/{dag_id}/updateTaskInstancesState | Set a state of task instances *DAGRunApi* | [**delete_dag_run**](docs/DAGRunApi.md#delete_dag_run) | **DELETE** /dags/{dag_id}/dagRuns/{dag_run_id} | Delete a DAG run *DAGRunApi* | [**get_dag_run**](docs/DAGRunApi.md#get_dag_run) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id} | Get a DAG run *DAGRunApi* | [**get_dag_runs**](docs/DAGRunApi.md#get_dag_runs) | **GET** /dags/{dag_id}/dagRuns | List DAG runs *DAGRunApi* | [**get_dag_runs_batch**](docs/DAGRunApi.md#get_dag_runs_batch) | **POST** /dags/~/dagRuns/list | List DAG runs (batch) *DAGRunApi* | [**post_dag_run**](docs/DAGRunApi.md#post_dag_run) | **POST** /dags/{dag_id}/dagRuns | Trigger a new DAG run *EventLogApi* | [**get_event_log**](docs/EventLogApi.md#get_event_log) | **GET** /eventLogs/{event_log_id} | Get a log entry *EventLogApi* | [**get_event_logs**](docs/EventLogApi.md#get_event_logs) | **GET** /eventLogs | List log entries *ImportErrorApi* | [**get_import_error**](docs/ImportErrorApi.md#get_import_error) | **GET** /importErrors/{import_error_id} | Get an import error *ImportErrorApi* | [**get_import_errors**](docs/ImportErrorApi.md#get_import_errors) | **GET** /importErrors | List import errors *MonitoringApi* | [**get_health**](docs/MonitoringApi.md#get_health) | **GET** /health | Get instance status *MonitoringApi* | [**get_version**](docs/MonitoringApi.md#get_version) | **GET** /version | Get version information *PoolApi* | [**delete_pool**](docs/PoolApi.md#delete_pool) | **DELETE** /pools/{pool_name} | Delete a pool *PoolApi* | [**get_pool**](docs/PoolApi.md#get_pool) | **GET** /pools/{pool_name} | Get a pool *PoolApi* | [**get_pools**](docs/PoolApi.md#get_pools) | **GET** /pools | List pools *PoolApi* | [**patch_pool**](docs/PoolApi.md#patch_pool) | **PATCH** /pools/{pool_name} | Update a pool *PoolApi* | [**post_pool**](docs/PoolApi.md#post_pool) | **POST** /pools | Create a pool *TaskInstanceApi* | [**get_extra_links**](docs/TaskInstanceApi.md#get_extra_links) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/links | List extra links *TaskInstanceApi* | [**get_log**](docs/TaskInstanceApi.md#get_log) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{task_try_number} | Get logs *TaskInstanceApi* | [**get_task_instance**](docs/TaskInstanceApi.md#get_task_instance) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} | Get a task instance *TaskInstanceApi* | [**get_task_instances**](docs/TaskInstanceApi.md#get_task_instances) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances | List task instances *TaskInstanceApi* | [**get_task_instances_batch**](docs/TaskInstanceApi.md#get_task_instances_batch) | **POST** /dags/~/dagRuns/~/taskInstances/list | List task instances (batch) *VariableApi* | [**delete_variable**](docs/VariableApi.md#delete_variable) | **DELETE** /variables/{variable_key} | Delete a variable *VariableApi* | [**get_variable**](docs/VariableApi.md#get_variable) | **GET** /variables/{variable_key} | Get a variable *VariableApi* | [**get_variables**](docs/VariableApi.md#get_variables) | **GET** /variables | List variables *VariableApi* | [**patch_variable**](docs/VariableApi.md#patch_variable) | **PATCH** /variables/{variable_key} | Update a variable *VariableApi* | [**post_variables**](docs/VariableApi.md#post_variables) | **POST** /variables | Create a variable *XComApi* | [**get_xcom_entries**](docs/XComApi.md#get_xcom_entries) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries | List XCom entries *XComApi* | [**get_xcom_entry**](docs/XComApi.md#get_xcom_entry) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries/{xcom_key} | Get an XCom entry ## Documentation For Models - [ClassReference](docs/ClassReference.md) - [ClearTaskInstance](docs/ClearTaskInstance.md) - [CollectionInfo](docs/CollectionInfo.md) - [Color](docs/Color.md) - [Config](docs/Config.md) - [ConfigOption](docs/ConfigOption.md) - [ConfigSection](docs/ConfigSection.md) - [Connection](docs/Connection.md) - [ConnectionAllOf](docs/ConnectionAllOf.md) - [ConnectionCollection](docs/ConnectionCollection.md) - [ConnectionCollectionAllOf](docs/ConnectionCollectionAllOf.md) - [ConnectionCollectionItem](docs/ConnectionCollectionItem.md) - [CronExpression](docs/CronExpression.md) - [DAG](docs/DAG.md) - [DAGCollection](docs/DAGCollection.md) - [DAGCollectionAllOf](docs/DAGCollectionAllOf.md) - [DAGDetail](docs/DAGDetail.md) - [DAGDetailAllOf](docs/DAGDetailAllOf.md) - [DAGRun](docs/DAGRun.md) - [DAGRunCollection](docs/DAGRunCollection.md) - [DAGRunCollectionAllOf](docs/DAGRunCollectionAllOf.md) - [DagState](docs/DagState.md) - [Error](docs/Error.md) - [EventLog](docs/EventLog.md) - [EventLogCollection](docs/EventLogCollection.md) - [EventLogCollectionAllOf](docs/EventLogCollectionAllOf.md) - [ExtraLink](docs/ExtraLink.md) - [ExtraLinkCollection](docs/ExtraLinkCollection.md) - [HealthInfo](docs/HealthInfo.md) - [HealthStatus](docs/HealthStatus.md) - [ImportError](docs/ImportError.md) - [ImportErrorCollection](docs/ImportErrorCollection.md) - [ImportErrorCollectionAllOf](docs/ImportErrorCollectionAllOf.md) - [InlineResponse200](docs/InlineResponse200.md) - [InlineResponse2001](docs/InlineResponse2001.md) - [ListDagRunsForm](docs/ListDagRunsForm.md) - [ListTaskInstanceForm](docs/ListTaskInstanceForm.md) - [MetadatabaseStatus](docs/MetadatabaseStatus.md) - [Pool](docs/Pool.md) - [PoolCollection](docs/PoolCollection.md) - [PoolCollectionAllOf](docs/PoolCollectionAllOf.md) - [RelativeDelta](docs/RelativeDelta.md) - [SLAMiss](docs/SLAMiss.md) - [ScheduleInterval](docs/ScheduleInterval.md) - [SchedulerStatus](docs/SchedulerStatus.md) - [Tag](docs/Tag.md) - [Task](docs/Task.md) - [TaskCollection](docs/TaskCollection.md) - [TaskCollectionAllOf](docs/TaskCollectionAllOf.md) - [TaskExtraLinks](docs/TaskExtraLinks.md) - [TaskInstance](docs/TaskInstance.md) - [TaskInstanceCollection](docs/TaskInstanceCollection.md) - [TaskInstanceCollectionAllOf](docs/TaskInstanceCollectionAllOf.md) - [TaskInstanceReference](docs/TaskInstanceReference.md) - [TaskInstanceReferenceCollection](docs/TaskInstanceReferenceCollection.md) - [TaskState](docs/TaskState.md) - [TimeDelta](docs/TimeDelta.md) - [TriggerRule](docs/TriggerRule.md) - [UpdateTaskInstancesState](docs/UpdateTaskInstancesState.md) - [Variable](docs/Variable.md) - [VariableAllOf](docs/VariableAllOf.md) - [VariableCollection](docs/VariableCollection.md) - [VariableCollectionAllOf](docs/VariableCollectionAllOf.md) - [VariableCollectionItem](docs/VariableCollectionItem.md) - [VersionInfo](docs/VersionInfo.md) - [WeightRule](docs/WeightRule.md) - [XCom](docs/XCom.md) - [XComAllOf](docs/XComAllOf.md) - [XComCollection](docs/XComCollection.md) - [XComCollectionAllOf](docs/XComCollectionAllOf.md) - [XComCollectionItem](docs/XComCollectionItem.md) ## Documentation For Authorization ## Basic - **Type**: HTTP basic authentication ## Kerberos ## Author zach.z.liu@gmail.com ## Notes for Large OpenAPI documents If the OpenAPI document is large, imports in airflow_python_sdk.apis and airflow_python_sdk.models may fail with a RecursionError indicating the maximum recursion limit has been exceeded. In that case, there are a couple of solutions: Solution 1: Use specific imports for apis and models like: - `from airflow_python_sdk.api.default_api import DefaultApi` - `from airflow_python_sdk.model.pet import Pet` Solution 1: Before importing the package, adjust the maximum recursion limit as shown below: ``` import sys sys.setrecursionlimit(1500) import airflow_python_sdk from airflow_python_sdk.apis import * from airflow_python_sdk.models import * ``` %package -n python3-airflow-python-sdk Summary: Airflow API (Stable) Provides: python-airflow-python-sdk BuildRequires: python3-devel BuildRequires: python3-setuptools BuildRequires: python3-pip %description -n python3-airflow-python-sdk *ConfigApi* | [**get_config**](docs/ConfigApi.md#get_config) | **GET** /config | Get current configuration *ConnectionApi* | [**delete_connection**](docs/ConnectionApi.md#delete_connection) | **DELETE** /connections/{connection_id} | Delete a connection *ConnectionApi* | [**get_connection**](docs/ConnectionApi.md#get_connection) | **GET** /connections/{connection_id} | Get a connection *ConnectionApi* | [**get_connections**](docs/ConnectionApi.md#get_connections) | **GET** /connections | List connections *ConnectionApi* | [**patch_connection**](docs/ConnectionApi.md#patch_connection) | **PATCH** /connections/{connection_id} | Update a connection *ConnectionApi* | [**post_connection**](docs/ConnectionApi.md#post_connection) | **POST** /connections | Create a connection *DAGApi* | [**get_dag**](docs/DAGApi.md#get_dag) | **GET** /dags/{dag_id} | Get basic information about a DAG *DAGApi* | [**get_dag_details**](docs/DAGApi.md#get_dag_details) | **GET** /dags/{dag_id}/details | Get a simplified representation of DAG *DAGApi* | [**get_dag_source**](docs/DAGApi.md#get_dag_source) | **GET** /dagSources/{file_token} | Get a source code *DAGApi* | [**get_dags**](docs/DAGApi.md#get_dags) | **GET** /dags | List DAGs *DAGApi* | [**get_task**](docs/DAGApi.md#get_task) | **GET** /dags/{dag_id}/tasks/{task_id} | Get simplified representation of a task *DAGApi* | [**get_tasks**](docs/DAGApi.md#get_tasks) | **GET** /dags/{dag_id}/tasks | Get tasks for DAG *DAGApi* | [**patch_dag**](docs/DAGApi.md#patch_dag) | **PATCH** /dags/{dag_id} | Update a DAG *DAGApi* | [**post_clear_task_instances**](docs/DAGApi.md#post_clear_task_instances) | **POST** /dags/{dag_id}/clearTaskInstances | Clear a set of task instances *DAGApi* | [**post_set_task_instances_state**](docs/DAGApi.md#post_set_task_instances_state) | **POST** /dags/{dag_id}/updateTaskInstancesState | Set a state of task instances *DAGRunApi* | [**delete_dag_run**](docs/DAGRunApi.md#delete_dag_run) | **DELETE** /dags/{dag_id}/dagRuns/{dag_run_id} | Delete a DAG run *DAGRunApi* | [**get_dag_run**](docs/DAGRunApi.md#get_dag_run) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id} | Get a DAG run *DAGRunApi* | [**get_dag_runs**](docs/DAGRunApi.md#get_dag_runs) | **GET** /dags/{dag_id}/dagRuns | List DAG runs *DAGRunApi* | [**get_dag_runs_batch**](docs/DAGRunApi.md#get_dag_runs_batch) | **POST** /dags/~/dagRuns/list | List DAG runs (batch) *DAGRunApi* | [**post_dag_run**](docs/DAGRunApi.md#post_dag_run) | **POST** /dags/{dag_id}/dagRuns | Trigger a new DAG run *EventLogApi* | [**get_event_log**](docs/EventLogApi.md#get_event_log) | **GET** /eventLogs/{event_log_id} | Get a log entry *EventLogApi* | [**get_event_logs**](docs/EventLogApi.md#get_event_logs) | **GET** /eventLogs | List log entries *ImportErrorApi* | [**get_import_error**](docs/ImportErrorApi.md#get_import_error) | **GET** /importErrors/{import_error_id} | Get an import error *ImportErrorApi* | [**get_import_errors**](docs/ImportErrorApi.md#get_import_errors) | **GET** /importErrors | List import errors *MonitoringApi* | [**get_health**](docs/MonitoringApi.md#get_health) | **GET** /health | Get instance status *MonitoringApi* | [**get_version**](docs/MonitoringApi.md#get_version) | **GET** /version | Get version information *PoolApi* | [**delete_pool**](docs/PoolApi.md#delete_pool) | **DELETE** /pools/{pool_name} | Delete a pool *PoolApi* | [**get_pool**](docs/PoolApi.md#get_pool) | **GET** /pools/{pool_name} | Get a pool *PoolApi* | [**get_pools**](docs/PoolApi.md#get_pools) | **GET** /pools | List pools *PoolApi* | [**patch_pool**](docs/PoolApi.md#patch_pool) | **PATCH** /pools/{pool_name} | Update a pool *PoolApi* | [**post_pool**](docs/PoolApi.md#post_pool) | **POST** /pools | Create a pool *TaskInstanceApi* | [**get_extra_links**](docs/TaskInstanceApi.md#get_extra_links) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/links | List extra links *TaskInstanceApi* | [**get_log**](docs/TaskInstanceApi.md#get_log) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{task_try_number} | Get logs *TaskInstanceApi* | [**get_task_instance**](docs/TaskInstanceApi.md#get_task_instance) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} | Get a task instance *TaskInstanceApi* | [**get_task_instances**](docs/TaskInstanceApi.md#get_task_instances) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances | List task instances *TaskInstanceApi* | [**get_task_instances_batch**](docs/TaskInstanceApi.md#get_task_instances_batch) | **POST** /dags/~/dagRuns/~/taskInstances/list | List task instances (batch) *VariableApi* | [**delete_variable**](docs/VariableApi.md#delete_variable) | **DELETE** /variables/{variable_key} | Delete a variable *VariableApi* | [**get_variable**](docs/VariableApi.md#get_variable) | **GET** /variables/{variable_key} | Get a variable *VariableApi* | [**get_variables**](docs/VariableApi.md#get_variables) | **GET** /variables | List variables *VariableApi* | [**patch_variable**](docs/VariableApi.md#patch_variable) | **PATCH** /variables/{variable_key} | Update a variable *VariableApi* | [**post_variables**](docs/VariableApi.md#post_variables) | **POST** /variables | Create a variable *XComApi* | [**get_xcom_entries**](docs/XComApi.md#get_xcom_entries) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries | List XCom entries *XComApi* | [**get_xcom_entry**](docs/XComApi.md#get_xcom_entry) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries/{xcom_key} | Get an XCom entry ## Documentation For Models - [ClassReference](docs/ClassReference.md) - [ClearTaskInstance](docs/ClearTaskInstance.md) - [CollectionInfo](docs/CollectionInfo.md) - [Color](docs/Color.md) - [Config](docs/Config.md) - [ConfigOption](docs/ConfigOption.md) - [ConfigSection](docs/ConfigSection.md) - [Connection](docs/Connection.md) - [ConnectionAllOf](docs/ConnectionAllOf.md) - [ConnectionCollection](docs/ConnectionCollection.md) - [ConnectionCollectionAllOf](docs/ConnectionCollectionAllOf.md) - [ConnectionCollectionItem](docs/ConnectionCollectionItem.md) - [CronExpression](docs/CronExpression.md) - [DAG](docs/DAG.md) - [DAGCollection](docs/DAGCollection.md) - [DAGCollectionAllOf](docs/DAGCollectionAllOf.md) - [DAGDetail](docs/DAGDetail.md) - [DAGDetailAllOf](docs/DAGDetailAllOf.md) - [DAGRun](docs/DAGRun.md) - [DAGRunCollection](docs/DAGRunCollection.md) - [DAGRunCollectionAllOf](docs/DAGRunCollectionAllOf.md) - [DagState](docs/DagState.md) - [Error](docs/Error.md) - [EventLog](docs/EventLog.md) - [EventLogCollection](docs/EventLogCollection.md) - [EventLogCollectionAllOf](docs/EventLogCollectionAllOf.md) - [ExtraLink](docs/ExtraLink.md) - [ExtraLinkCollection](docs/ExtraLinkCollection.md) - [HealthInfo](docs/HealthInfo.md) - [HealthStatus](docs/HealthStatus.md) - [ImportError](docs/ImportError.md) - [ImportErrorCollection](docs/ImportErrorCollection.md) - [ImportErrorCollectionAllOf](docs/ImportErrorCollectionAllOf.md) - [InlineResponse200](docs/InlineResponse200.md) - [InlineResponse2001](docs/InlineResponse2001.md) - [ListDagRunsForm](docs/ListDagRunsForm.md) - [ListTaskInstanceForm](docs/ListTaskInstanceForm.md) - [MetadatabaseStatus](docs/MetadatabaseStatus.md) - [Pool](docs/Pool.md) - [PoolCollection](docs/PoolCollection.md) - [PoolCollectionAllOf](docs/PoolCollectionAllOf.md) - [RelativeDelta](docs/RelativeDelta.md) - [SLAMiss](docs/SLAMiss.md) - [ScheduleInterval](docs/ScheduleInterval.md) - [SchedulerStatus](docs/SchedulerStatus.md) - [Tag](docs/Tag.md) - [Task](docs/Task.md) - [TaskCollection](docs/TaskCollection.md) - [TaskCollectionAllOf](docs/TaskCollectionAllOf.md) - [TaskExtraLinks](docs/TaskExtraLinks.md) - [TaskInstance](docs/TaskInstance.md) - [TaskInstanceCollection](docs/TaskInstanceCollection.md) - [TaskInstanceCollectionAllOf](docs/TaskInstanceCollectionAllOf.md) - [TaskInstanceReference](docs/TaskInstanceReference.md) - [TaskInstanceReferenceCollection](docs/TaskInstanceReferenceCollection.md) - [TaskState](docs/TaskState.md) - [TimeDelta](docs/TimeDelta.md) - [TriggerRule](docs/TriggerRule.md) - [UpdateTaskInstancesState](docs/UpdateTaskInstancesState.md) - [Variable](docs/Variable.md) - [VariableAllOf](docs/VariableAllOf.md) - [VariableCollection](docs/VariableCollection.md) - [VariableCollectionAllOf](docs/VariableCollectionAllOf.md) - [VariableCollectionItem](docs/VariableCollectionItem.md) - [VersionInfo](docs/VersionInfo.md) - [WeightRule](docs/WeightRule.md) - [XCom](docs/XCom.md) - [XComAllOf](docs/XComAllOf.md) - [XComCollection](docs/XComCollection.md) - [XComCollectionAllOf](docs/XComCollectionAllOf.md) - [XComCollectionItem](docs/XComCollectionItem.md) ## Documentation For Authorization ## Basic - **Type**: HTTP basic authentication ## Kerberos ## Author zach.z.liu@gmail.com ## Notes for Large OpenAPI documents If the OpenAPI document is large, imports in airflow_python_sdk.apis and airflow_python_sdk.models may fail with a RecursionError indicating the maximum recursion limit has been exceeded. In that case, there are a couple of solutions: Solution 1: Use specific imports for apis and models like: - `from airflow_python_sdk.api.default_api import DefaultApi` - `from airflow_python_sdk.model.pet import Pet` Solution 1: Before importing the package, adjust the maximum recursion limit as shown below: ``` import sys sys.setrecursionlimit(1500) import airflow_python_sdk from airflow_python_sdk.apis import * from airflow_python_sdk.models import * ``` %package help Summary: Development documents and examples for airflow-python-sdk Provides: python3-airflow-python-sdk-doc %description help *ConfigApi* | [**get_config**](docs/ConfigApi.md#get_config) | **GET** /config | Get current configuration *ConnectionApi* | [**delete_connection**](docs/ConnectionApi.md#delete_connection) | **DELETE** /connections/{connection_id} | Delete a connection *ConnectionApi* | [**get_connection**](docs/ConnectionApi.md#get_connection) | **GET** /connections/{connection_id} | Get a connection *ConnectionApi* | [**get_connections**](docs/ConnectionApi.md#get_connections) | **GET** /connections | List connections *ConnectionApi* | [**patch_connection**](docs/ConnectionApi.md#patch_connection) | **PATCH** /connections/{connection_id} | Update a connection *ConnectionApi* | [**post_connection**](docs/ConnectionApi.md#post_connection) | **POST** /connections | Create a connection *DAGApi* | [**get_dag**](docs/DAGApi.md#get_dag) | **GET** /dags/{dag_id} | Get basic information about a DAG *DAGApi* | [**get_dag_details**](docs/DAGApi.md#get_dag_details) | **GET** /dags/{dag_id}/details | Get a simplified representation of DAG *DAGApi* | [**get_dag_source**](docs/DAGApi.md#get_dag_source) | **GET** /dagSources/{file_token} | Get a source code *DAGApi* | [**get_dags**](docs/DAGApi.md#get_dags) | **GET** /dags | List DAGs *DAGApi* | [**get_task**](docs/DAGApi.md#get_task) | **GET** /dags/{dag_id}/tasks/{task_id} | Get simplified representation of a task *DAGApi* | [**get_tasks**](docs/DAGApi.md#get_tasks) | **GET** /dags/{dag_id}/tasks | Get tasks for DAG *DAGApi* | [**patch_dag**](docs/DAGApi.md#patch_dag) | **PATCH** /dags/{dag_id} | Update a DAG *DAGApi* | [**post_clear_task_instances**](docs/DAGApi.md#post_clear_task_instances) | **POST** /dags/{dag_id}/clearTaskInstances | Clear a set of task instances *DAGApi* | [**post_set_task_instances_state**](docs/DAGApi.md#post_set_task_instances_state) | **POST** /dags/{dag_id}/updateTaskInstancesState | Set a state of task instances *DAGRunApi* | [**delete_dag_run**](docs/DAGRunApi.md#delete_dag_run) | **DELETE** /dags/{dag_id}/dagRuns/{dag_run_id} | Delete a DAG run *DAGRunApi* | [**get_dag_run**](docs/DAGRunApi.md#get_dag_run) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id} | Get a DAG run *DAGRunApi* | [**get_dag_runs**](docs/DAGRunApi.md#get_dag_runs) | **GET** /dags/{dag_id}/dagRuns | List DAG runs *DAGRunApi* | [**get_dag_runs_batch**](docs/DAGRunApi.md#get_dag_runs_batch) | **POST** /dags/~/dagRuns/list | List DAG runs (batch) *DAGRunApi* | [**post_dag_run**](docs/DAGRunApi.md#post_dag_run) | **POST** /dags/{dag_id}/dagRuns | Trigger a new DAG run *EventLogApi* | [**get_event_log**](docs/EventLogApi.md#get_event_log) | **GET** /eventLogs/{event_log_id} | Get a log entry *EventLogApi* | [**get_event_logs**](docs/EventLogApi.md#get_event_logs) | **GET** /eventLogs | List log entries *ImportErrorApi* | [**get_import_error**](docs/ImportErrorApi.md#get_import_error) | **GET** /importErrors/{import_error_id} | Get an import error *ImportErrorApi* | [**get_import_errors**](docs/ImportErrorApi.md#get_import_errors) | **GET** /importErrors | List import errors *MonitoringApi* | [**get_health**](docs/MonitoringApi.md#get_health) | **GET** /health | Get instance status *MonitoringApi* | [**get_version**](docs/MonitoringApi.md#get_version) | **GET** /version | Get version information *PoolApi* | [**delete_pool**](docs/PoolApi.md#delete_pool) | **DELETE** /pools/{pool_name} | Delete a pool *PoolApi* | [**get_pool**](docs/PoolApi.md#get_pool) | **GET** /pools/{pool_name} | Get a pool *PoolApi* | [**get_pools**](docs/PoolApi.md#get_pools) | **GET** /pools | List pools *PoolApi* | [**patch_pool**](docs/PoolApi.md#patch_pool) | **PATCH** /pools/{pool_name} | Update a pool *PoolApi* | [**post_pool**](docs/PoolApi.md#post_pool) | **POST** /pools | Create a pool *TaskInstanceApi* | [**get_extra_links**](docs/TaskInstanceApi.md#get_extra_links) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/links | List extra links *TaskInstanceApi* | [**get_log**](docs/TaskInstanceApi.md#get_log) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{task_try_number} | Get logs *TaskInstanceApi* | [**get_task_instance**](docs/TaskInstanceApi.md#get_task_instance) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} | Get a task instance *TaskInstanceApi* | [**get_task_instances**](docs/TaskInstanceApi.md#get_task_instances) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances | List task instances *TaskInstanceApi* | [**get_task_instances_batch**](docs/TaskInstanceApi.md#get_task_instances_batch) | **POST** /dags/~/dagRuns/~/taskInstances/list | List task instances (batch) *VariableApi* | [**delete_variable**](docs/VariableApi.md#delete_variable) | **DELETE** /variables/{variable_key} | Delete a variable *VariableApi* | [**get_variable**](docs/VariableApi.md#get_variable) | **GET** /variables/{variable_key} | Get a variable *VariableApi* | [**get_variables**](docs/VariableApi.md#get_variables) | **GET** /variables | List variables *VariableApi* | [**patch_variable**](docs/VariableApi.md#patch_variable) | **PATCH** /variables/{variable_key} | Update a variable *VariableApi* | [**post_variables**](docs/VariableApi.md#post_variables) | **POST** /variables | Create a variable *XComApi* | [**get_xcom_entries**](docs/XComApi.md#get_xcom_entries) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries | List XCom entries *XComApi* | [**get_xcom_entry**](docs/XComApi.md#get_xcom_entry) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries/{xcom_key} | Get an XCom entry ## Documentation For Models - [ClassReference](docs/ClassReference.md) - [ClearTaskInstance](docs/ClearTaskInstance.md) - [CollectionInfo](docs/CollectionInfo.md) - [Color](docs/Color.md) - [Config](docs/Config.md) - [ConfigOption](docs/ConfigOption.md) - [ConfigSection](docs/ConfigSection.md) - [Connection](docs/Connection.md) - [ConnectionAllOf](docs/ConnectionAllOf.md) - [ConnectionCollection](docs/ConnectionCollection.md) - [ConnectionCollectionAllOf](docs/ConnectionCollectionAllOf.md) - [ConnectionCollectionItem](docs/ConnectionCollectionItem.md) - [CronExpression](docs/CronExpression.md) - [DAG](docs/DAG.md) - [DAGCollection](docs/DAGCollection.md) - [DAGCollectionAllOf](docs/DAGCollectionAllOf.md) - [DAGDetail](docs/DAGDetail.md) - [DAGDetailAllOf](docs/DAGDetailAllOf.md) - [DAGRun](docs/DAGRun.md) - [DAGRunCollection](docs/DAGRunCollection.md) - [DAGRunCollectionAllOf](docs/DAGRunCollectionAllOf.md) - [DagState](docs/DagState.md) - [Error](docs/Error.md) - [EventLog](docs/EventLog.md) - [EventLogCollection](docs/EventLogCollection.md) - [EventLogCollectionAllOf](docs/EventLogCollectionAllOf.md) - [ExtraLink](docs/ExtraLink.md) - [ExtraLinkCollection](docs/ExtraLinkCollection.md) - [HealthInfo](docs/HealthInfo.md) - [HealthStatus](docs/HealthStatus.md) - [ImportError](docs/ImportError.md) - [ImportErrorCollection](docs/ImportErrorCollection.md) - [ImportErrorCollectionAllOf](docs/ImportErrorCollectionAllOf.md) - [InlineResponse200](docs/InlineResponse200.md) - [InlineResponse2001](docs/InlineResponse2001.md) - [ListDagRunsForm](docs/ListDagRunsForm.md) - [ListTaskInstanceForm](docs/ListTaskInstanceForm.md) - [MetadatabaseStatus](docs/MetadatabaseStatus.md) - [Pool](docs/Pool.md) - [PoolCollection](docs/PoolCollection.md) - [PoolCollectionAllOf](docs/PoolCollectionAllOf.md) - [RelativeDelta](docs/RelativeDelta.md) - [SLAMiss](docs/SLAMiss.md) - [ScheduleInterval](docs/ScheduleInterval.md) - [SchedulerStatus](docs/SchedulerStatus.md) - [Tag](docs/Tag.md) - [Task](docs/Task.md) - [TaskCollection](docs/TaskCollection.md) - [TaskCollectionAllOf](docs/TaskCollectionAllOf.md) - [TaskExtraLinks](docs/TaskExtraLinks.md) - [TaskInstance](docs/TaskInstance.md) - [TaskInstanceCollection](docs/TaskInstanceCollection.md) - [TaskInstanceCollectionAllOf](docs/TaskInstanceCollectionAllOf.md) - [TaskInstanceReference](docs/TaskInstanceReference.md) - [TaskInstanceReferenceCollection](docs/TaskInstanceReferenceCollection.md) - [TaskState](docs/TaskState.md) - [TimeDelta](docs/TimeDelta.md) - [TriggerRule](docs/TriggerRule.md) - [UpdateTaskInstancesState](docs/UpdateTaskInstancesState.md) - [Variable](docs/Variable.md) - [VariableAllOf](docs/VariableAllOf.md) - [VariableCollection](docs/VariableCollection.md) - [VariableCollectionAllOf](docs/VariableCollectionAllOf.md) - [VariableCollectionItem](docs/VariableCollectionItem.md) - [VersionInfo](docs/VersionInfo.md) - [WeightRule](docs/WeightRule.md) - [XCom](docs/XCom.md) - [XComAllOf](docs/XComAllOf.md) - [XComCollection](docs/XComCollection.md) - [XComCollectionAllOf](docs/XComCollectionAllOf.md) - [XComCollectionItem](docs/XComCollectionItem.md) ## Documentation For Authorization ## Basic - **Type**: HTTP basic authentication ## Kerberos ## Author zach.z.liu@gmail.com ## Notes for Large OpenAPI documents If the OpenAPI document is large, imports in airflow_python_sdk.apis and airflow_python_sdk.models may fail with a RecursionError indicating the maximum recursion limit has been exceeded. In that case, there are a couple of solutions: Solution 1: Use specific imports for apis and models like: - `from airflow_python_sdk.api.default_api import DefaultApi` - `from airflow_python_sdk.model.pet import Pet` Solution 1: Before importing the package, adjust the maximum recursion limit as shown below: ``` import sys sys.setrecursionlimit(1500) import airflow_python_sdk from airflow_python_sdk.apis import * from airflow_python_sdk.models import * ``` %prep %autosetup -n airflow-python-sdk-1.0.1 %build %py3_build %install %py3_install install -d -m755 %{buildroot}/%{_pkgdocdir} if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi pushd %{buildroot} if [ -d usr/lib ]; then find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst fi if [ -d usr/lib64 ]; then find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst fi if [ -d usr/bin ]; then find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst fi if [ -d usr/sbin ]; then find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst fi touch doclist.lst if [ -d usr/share/man ]; then find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst fi popd mv %{buildroot}/filelist.lst . mv %{buildroot}/doclist.lst . %files -n python3-airflow-python-sdk -f filelist.lst %dir %{python3_sitelib}/* %files help -f doclist.lst %{_docdir}/* %changelog * Fri May 05 2023 Python_Bot - 1.0.1-1 - Package Spec generated