filter out data objects with no data_object_type

microbiomedata · Nov 20, 2024 · 7660a91 · 7660a91
1 parent cbec96c
commit 7660a91
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nmdc_automation/workflow_automation/workflow_process.py b/nmdc_automation/workflow_automation/workflow_process.py
@@ -26,7 +26,7 @@ def get_required_data_objects_map(db, workflows: List[WorkflowConfig]) -> Dict[s
         required_types.update(set(wf.data_object_types))
 
     required_data_objs_by_id = dict()
-    for rec in db.data_object_set.find():
+    for rec in db.data_object_set.find({"data_object_type": {"$ne": None}}):
         do = DataObject(**rec)
         if do.data_object_type.code.text not in required_types:
             continue