bugfix del var that might not exist

skyportal · Jul 14, 2023 · 46577d1 · 46577d1
1 parent b75ce6d
commit 46577d1
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 0 deletions.
diff --git a/kowalski/alert_brokers/alert_broker_pgir.py b/kowalski/alert_brokers/alert_broker_pgir.py
@@ -75,6 +75,7 @@ def process_alert(alert: Mapping, topic: str):
                 and len(existing_aux.get("prv_candidates", [])) > 0
             ):
                 all_prv_candidates += existing_aux["prv_candidates"]
+            del existing_aux
 
         # ML models:
         with timer(f"MLing of {object_id} {candid}", alert_worker.verbose > 1):
@@ -92,6 +93,7 @@ def process_alert(alert: Mapping, topic: str):
             for prv_candidate in prv_candidates
         ]
 
+        alert_aux, xmatches, xmatches_ztf, passed_filters = None, None, None, None
         # cross-match with external catalogs if objectId not in collection_alerts_aux:
         if (
             alert_worker.mongo.db[alert_worker.collection_alerts_aux].count_documents(

diff --git a/kowalski/alert_brokers/alert_broker_turbo.py b/kowalski/alert_brokers/alert_broker_turbo.py
@@ -71,6 +71,7 @@ def process_alert(alert: Mapping, topic: str):
             for prv_candidate in prv_candidates
         ]
 
+        alert_aux, xmatches, xmatches_ztf, passed_filters = None, None, None, None
         # cross-match with external catalogs if objectId not in collection_alerts_aux:
         if (
             alert_worker.mongo.db[alert_worker.collection_alerts_aux].count_documents(

diff --git a/kowalski/alert_brokers/alert_broker_winter.py b/kowalski/alert_brokers/alert_broker_winter.py
@@ -94,6 +94,8 @@ def process_alert(alert: Mapping, topic: str):
             {kk: vv for kk, vv in prv_candidate.items() if vv is not None}
             for prv_candidate in prv_candidates
         ]
+
+        alert_aux, xmatches, xmatches_ztf, passed_filters = None, None, None, None
         # cross-match with external catalogs if objectId not in collection_alerts_aux:
         if (
             alert_worker.mongo.db[alert_worker.collection_alerts_aux].count_documents(

diff --git a/kowalski/alert_brokers/alert_broker_ztf.py b/kowalski/alert_brokers/alert_broker_ztf.py
@@ -75,6 +75,7 @@ def process_alert(alert: Mapping, topic: str):
                 and len(existing_aux.get("prv_candidates", [])) > 0
             ):
                 all_prv_candidates += existing_aux["prv_candidates"]
+            del existing_aux
 
         # ML models:
         with timer(f"MLing of {object_id} {candid}", alert_worker.verbose > 1):
@@ -92,6 +93,7 @@ def process_alert(alert: Mapping, topic: str):
             for prv_candidate in prv_candidates
         ]
 
+        alert_aux, xmatches, passed_filters = None, None, None
         # cross-match with external catalogs if objectId not in collection_alerts_aux:
         if (
             retry(