diff --git a/prv_candidates_step/prv_candidates_step/core/strategy/lsst.py b/prv_candidates_step/prv_candidates_step/core/strategy/lsst.py
index 9533b328b..6888731eb 100644
--- a/prv_candidates_step/prv_candidates_step/core/strategy/lsst.py
+++ b/prv_candidates_step/prv_candidates_step/core/strategy/lsst.py
@@ -44,7 +44,7 @@ def parse(cls, message: dict, ra: float, dec: float) -> dict:
 def extract_detections_and_non_detections(alert: dict) -> dict:
     prv_candidates = alert["extra_fields"].pop("prvDiaSources")
     prv_forced = alert["extra_fields"].pop("prvDiaForcedSources")
-    
+
     detections = [alert.copy()]
 
     aid, parent = alert["aid"], alert["candid"]
diff --git a/prv_candidates_step/prv_candidates_step/step.py b/prv_candidates_step/prv_candidates_step/step.py
index 1fa895545..250f4364b 100644
--- a/prv_candidates_step/prv_candidates_step/step.py
+++ b/prv_candidates_step/prv_candidates_step/step.py
@@ -53,7 +53,9 @@ def post_execute(self, result: List[dict]):
                 msg["candid"] for msg in result if msg["candid"] == CANDID_SEARCH
             ]
             if len(with_candid) == 0:
-                raise Exception(f"=====\nALERT WITH CANDID {CANDID_SEARCH} DISAPPEARED!")
+                raise Exception(
+                    f"=====\nALERT WITH CANDID {CANDID_SEARCH} DISAPPEARED!"
+                )
         for alert in result:
             non_detections = alert["non_detections"]
             self.produce_scribe(non_detections)
diff --git a/xmatch_step/xmatch_step/step.py b/xmatch_step/xmatch_step/step.py
index fd463e58c..5aeba13d2 100755
--- a/xmatch_step/xmatch_step/step.py
+++ b/xmatch_step/xmatch_step/step.py
@@ -74,7 +74,6 @@ def _add_non_detection(message):
             )
             return message
 
-        self.set_producer_key_field("aid")
         return list(map(_add_non_detection, result))
 
     def request_xmatch(