birbnetes/classification-service
Archived
4
0
Fork 0
Code Issues Releases Activity

Fixed serialization
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Pünkösd Marcell
2020-05-05 23:44:28 +02:00
parent 6c1c581b80
commit bc88a6aa45
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
classification_service/mule.py
View File

@@ -84,7 +84,7 @@ def main():
message = uwsgi.mule_get_msg() message = uwsgi.mule_get_msg()
task = json.loads(message) task = json.loads(message)
results = run_classification(task) results = run_classification(task)
channel.basic_publish(exchange=os.environ['PIKA_EXCHANGE'], routing_key='classification-result', body=results) channel.basic_publish(exchange=os.environ['PIKA_EXCHANGE'], routing_key='classification-result', body=json.dumps(results).encode("utf-8"))
if __name__ == '__main__': if __name__ == '__main__':