Merge pull request #97 from ssi-dk/skp/fix-tbr-sync

fix: dont sync samples without isolate_id
ssi-dk · Sep 9, 2024 · dd26e1c · dd26e1c
2 parents 6ba1ab3 + a645864
commit dd26e1c
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/bifrost/bifrost_queue_broker/brokers/pulling/tbr_pulling_broker.py b/bifrost/bifrost_queue_broker/brokers/pulling/tbr_pulling_broker.py
@@ -85,9 +85,12 @@ def run_sync_job(self):
             # {"$unwind": {"path": "$metadata", "preserveNullAndEmptyArrays": True}},
             {
                 "$match": {
-                    "$or": [
-                        {"metadata.gdpr_deleted": {"$exists": False}},
-                        {"metadata.gdpr_deleted": False},
+                    "$and": [
+                        {"isolate_id": {"$ne": null}},
+                        {"$or": [                         
+                            {"metadata.gdpr_deleted": {"$exists": False}},
+                            {"metadata.gdpr_deleted": False},
+                        ]}
                     ]
                 }
             },