addition of code to filter out nowcast runs

src/common/pg_impl.py

@@ -48,13 +48,14 @@ def __del__(self):
         # clean up connections and cursors
         PGUtilsMultiConnect.__del__(self)
 
-    def get_catalog_member_records(self, run_id: str = None, project_code: str = None, limit: int = None) -> dict:
+    def get_catalog_member_records(self, run_id: str = None, project_code: str = None, filter_event_type: str = None, limit: int = None) -> dict:
         """
         gets the apsviz catalog member record for the run id passed. the SP default
         record count returned can be overridden.
 
         :param run_id:
         :param project_code:
+        :param filter_event_type:
         :param limit:
         :return:
         """
@@ -74,14 +75,20 @@ def get_catalog_member_records(self, run_id: str = None, project_code: str = Non
         else:
             project_code = ', _project_code := NULL'
 
+        # did we get a filter event type
+        if filter_event_type is not None:
+            filter_event_type = f", _filter_event_type := '{filter_event_type}'"
+        else:
+            filter_event_type = ', _filter_event_type := NULL'
+
         # did we get a limit
         if limit is not None:
             limit = f', _limit := {limit}'
         else:
             limit = ', _limit := NULL'
 
         # create the sql. note we are appending a '%' wildcard to get all products for this run
-        sql: str = f"SELECT public.get_catalog_member_records({run_id}{project_code}{limit});"
+        sql: str = f"SELECT public.get_catalog_member_records({run_id}{project_code}{filter_event_type}{limit});"
 
         # get the layer list
         ret_val = self.exec_sql('apsviz', sql)

src/sync/psc_sync.py

@@ -67,7 +67,7 @@ def run(self, run_id: str, physical_location: str) -> bool:
         if physical_location.startswith(self.psc_physical_location):
             try:
                 # make the DB request to get the catalogs
-                catalog_data: dict = self.db_info.get_catalog_member_records(run_id)
+                catalog_data: dict = self.db_info.get_catalog_member_records(run_id=run_id, filter_event_type='nowcast')
 
                 # if we got data push it to PSC
                 if catalog_data is not None and catalog_data['catalogs'] is not None: