Move headers

import_api_app/resources/UpdateInstitution.py

@@ -139,14 +139,14 @@ class UpdateInstitution(Resource):
                 institution_data_de['attributes']['computed_teaser_image_url'],
             'computed_teaser_color': institution_data_de['attributes']['computed_teaser_color'],
         }
-        producer_topic = current_app.config['topic-drupal-export']
-        headers = [
-            ('recordSetId', bytes('none', encoding='utf-8')),
-            ('sessionId', bytes(str(uuid.uuid4()), encoding='utf-8')),
-            ('institutionId', bytes(result.get('field_memobase_id'), encoding='utf-8')),
-            ('isPublished', bytes(str(result['status']), encoding='utf-8'))
-        ]
         try:
+            producer_topic = current_app.config['topic-drupal-export']
+            headers = [
+                ('recordSetId', bytes('none', encoding='utf-8')),
+                ('sessionId', bytes(str(uuid.uuid4()), encoding='utf-8')),
+                ('institutionId', bytes(result.get('field_memobase_id'), encoding='utf-8')),
+                ('isPublished', bytes(str(result['status']), encoding='utf-8'))
+            ]
             key = bytes(result.get('field_memobase_id'), encoding='utf-8')
             self.producer.send(producer_topic, result, key, headers=headers)
         except Exception as ex: