| 
									
										
										
										
											2022-07-28 14:46:25 +02:00
										 |  |  | #  Copyright 2021 Collate | 
					
						
							|  |  |  | #  Licensed under the Apache License, Version 2.0 (the "License"); | 
					
						
							|  |  |  | #  you may not use this file except in compliance with the License. | 
					
						
							|  |  |  | #  You may obtain a copy of the License at | 
					
						
							|  |  |  | #  http://www.apache.org/licenses/LICENSE-2.0 | 
					
						
							|  |  |  | #  Unless required by applicable law or agreed to in writing, software | 
					
						
							|  |  |  | #  distributed under the License is distributed on an "AS IS" BASIS, | 
					
						
							|  |  |  | #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
					
						
							|  |  |  | #  See the License for the specific language governing permissions and | 
					
						
							|  |  |  | #  limitations under the License. | 
					
						
							|  |  |  | """
 | 
					
						
							|  |  |  | Health endpoint. Globally accessible | 
					
						
							|  |  |  | """
 | 
					
						
							| 
									
										
										
										
											2022-09-15 10:32:54 +02:00
										 |  |  | from typing import Callable | 
					
						
							| 
									
										
										
										
											2022-07-28 14:46:25 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-09-15 10:32:54 +02:00
										 |  |  | from flask import Blueprint | 
					
						
							| 
									
										
										
										
											2023-06-12 07:47:45 +02:00
										 |  |  | from openmetadata_managed_apis.operations.health import health_response | 
					
						
							| 
									
										
										
										
											2022-08-26 07:29:38 +02:00
										 |  |  | from openmetadata_managed_apis.utils.logger import routes_logger | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-08-23 08:59:44 +02:00
										 |  |  | try: | 
					
						
							| 
									
										
										
										
											2023-10-04 09:14:03 +02:00
										 |  |  |     pass | 
					
						
							| 
									
										
										
										
											2022-08-23 08:59:44 +02:00
										 |  |  | except ImportError: | 
					
						
							| 
									
										
										
										
											2023-10-04 09:14:03 +02:00
										 |  |  |     pass | 
					
						
							| 
									
										
										
										
											2022-08-23 08:59:44 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-08-26 07:29:38 +02:00
										 |  |  | logger = routes_logger() | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-07-28 14:46:25 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-09-15 10:32:54 +02:00
										 |  |  | def get_fn(blueprint: Blueprint) -> Callable: | 
					
						
							| 
									
										
										
										
											2022-07-28 14:46:25 +02:00
										 |  |  |     """
 | 
					
						
							| 
									
										
										
										
											2022-09-15 10:32:54 +02:00
										 |  |  |     Return the function loaded to a route | 
					
						
							|  |  |  |     :param blueprint: Flask Blueprint to assign route to | 
					
						
							|  |  |  |     :return: routed function | 
					
						
							| 
									
										
										
										
											2022-07-28 14:46:25 +02:00
										 |  |  |     """
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-09-15 10:32:54 +02:00
										 |  |  |     # Lazy import the requirements | 
					
						
							|  |  |  |     # pylint: disable=import-outside-toplevel | 
					
						
							|  |  |  |     from airflow.www.app import csrf | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     @blueprint.route("/health", methods=["GET"]) | 
					
						
							|  |  |  |     @csrf.exempt | 
					
						
							|  |  |  |     def health(): | 
					
						
							|  |  |  |         """
 | 
					
						
							|  |  |  |         /health endpoint to check Airflow REST status without auth | 
					
						
							|  |  |  |         """
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2023-06-12 07:47:45 +02:00
										 |  |  |         return health_response() | 
					
						
							| 
									
										
										
										
											2022-09-15 10:32:54 +02:00
										 |  |  | 
 | 
					
						
							|  |  |  |     return health |