This new check-in implements GAIAPCR-1094: Astroquery Use TAP notifications service to notify users of service availability problems

Author: mhsarmiento

astroquery/gaia/__init__.py

@@ -39,6 +39,8 @@ class Conf(_config.ConfigNamespace):
                                       'MCMC_GSPPHOT',
                                       'MCMC_MSC']
 
+    GAIA_MESSAGES = _config.ConfigItem("notification?action=GetNotifications", "Gaia Messages")
+
 
 conf = Conf()
 

astroquery/gaia/core.py

@@ -51,7 +51,7 @@ def __init__(self, tap_plus_conn_handler=None,
                  gaia_data_server='https://gea.esac.esa.int/',
                  tap_server_context="tap-server",
                  data_server_context="data-server",
-                 verbose=False):
+                 verbose=False, show_messages=True):
         super(GaiaClass, self).__init__(url=gaia_tap_server,
                                         server_context=tap_server_context,
                                         tap_context="tap",
@@ -74,6 +74,10 @@ def __init__(self, tap_plus_conn_handler=None,
         else:
             self.__gaiadata = datalink_handler
 
+        # Enable notifications
+        if show_messages:
+            self.get_status_messages()
+
     def login(self, user=None, password=None, credentials_file=None,
               verbose=False):
         """Performs a login.
@@ -911,5 +915,20 @@ def launch_job_async(self, query, name=None, output_file=None,
                                         upload_table_name=upload_table_name,
                                         autorun=autorun)
 
+    def get_status_messages(self):
+        """Retrieve the messages to inform users about
+        the status of JWST TAP
+        """
+        try:
+            subContext = conf.GAIA_MESSAGES
+            connHandler = self._TapPlus__getconnhandler()
+            response = connHandler.execute_tapget(subContext, False)
+            if response.status == 200:
+                for line in response:
+                    string_message = line.decode("utf-8")
+                    print(string_message[string_message.index('=') + 1:])
+        except OSError as e:
+            print("Status messages could not be retrieved")
+
 
 Gaia = GaiaClass()