fixed record compiler

open-contracting · Aug 12, 2021 · 055e035 · 055e035
1 parent b59fa1f
commit 055e035
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/process/management/commands/record_compiler.py b/process/management/commands/record_compiler.py
@@ -41,14 +41,19 @@ def process(self, connection, channel, delivery_tag, body):
 
             self._deleteStep(ProcessingStep.Types.COMPILE, collection_id=collection_id, ocid=ocid)
 
+            compiled_collection = Collection.objects.get(id=input_message["collection_id"])
+
             release_id = None
+            release_collection_id = None
+
             if release:
                 release_id = release.pk
+
             # publish message about processed item
             message = {
                 "ocid": ocid,
                 "compiled_release_id": release_id,
-                "collection_id": collection_id,
+                "collection_id": compiled_collection.id,
             }
 
             self._publish_async(connection, channel, json.dumps(message))