fix mypy check

materialsproject · May 25, 2020 · 1c08fe7 · 1c08fe7
1 parent 9f70ef3
commit 1c08fe7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/maggma/builders/group_builder.py b/src/maggma/builders/group_builder.py
@@ -214,7 +214,7 @@ def get_ids_to_process(self) -> Iterable:
             failed_keys = self.target.distinct(
                 self._target_keys_field, criteria={"state": "failed", **query}
             )
-            unprocessed_ids = all_ids - set(processed_ids) + set(failed_keys)
+            unprocessed_ids = all_ids - (set(processed_ids) - set(failed_keys))
             self.logger.debug(f"Found {len(failed_keys)} failed IDs in target")
         else:
             unprocessed_ids = all_ids - set(processed_ids)