Use actual destination to report back to DANE

beeldengeluid · Aug 2, 2024 · d558963 · d558963
1 parent db6d90c
commit d558963
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/worker.py b/worker.py
@@ -79,11 +79,12 @@ def callback(self, task: Task, doc: Document) -> CallbackResponse:
             logger.info(
                 "applying IO on output went well, now finally saving to DANE index"
             )
+
             try:
                 self.save_to_dane_index(
                     doc,
                     task,
-                    get_s3_output_file_uri(get_source_id(input_file_path), with_tar=cfg.OUTPUT.TAR_OUTPUT),
+                    processing_result.get("destination", "nowhere"),
                     provenance=full_provenance_chain,
                 )
             except Exception as e: