Commit f70dedaf authored by Matthias's avatar Matthias
Browse files

Merge remote-tracking branch 'origin/master'

parents 984dbeea 3e0b5a88
Pipeline #24959 passed with stages
in 2 minutes and 30 seconds
......@@ -146,7 +146,7 @@ class MonitorDrupalJsonApiInstitution(Resource):
value_serializer=lambda m: json.dumps(m, ensure_ascii=False)
.encode('utf-8'))
key = bytes(topic_value.get('field_memobase_id'), encoding='utf-8')
producer.send('drupal-json-api-input', topic_value, key)
producer.send('mb-gi-drupal-export-prod', topic_value, key)
except Exception as ex:
msg = 'Exception for ' + institutionId + ': ' + str(ex) + '\n' + \
traceback.format_exc()
......
......@@ -211,7 +211,7 @@ class MonitorDrupalJsonApiRecordSet(Resource):
value_serializer=lambda m: json.dumps(m, ensure_ascii=False)
.encode('utf-8'))
key = bytes(topicValue.get('field_memobase_id'), encoding='utf-8')
producer.send('drupal-json-api-input', topicValue, key=key)
producer.send('mb-gi-drupal-export-prod', topicValue, key=key)
except Exception as ex:
msg = 'Exception for ' + recordSetId + ': ' + str(ex) + '\n' +\
traceback.format_exc()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment