Add byUserId to message payload in worker for enhanced metadata
Build image and push it to registry / build (push) Successful in 1m25s
Build image and push it to registry / build (push) Successful in 1m25s
This commit is contained in:
@@ -61,6 +61,7 @@ def on_message(channel, method_frame, header_frame, body):
|
|||||||
channel.basic_publish(exchange=EXCHANGE_OUT,
|
channel.basic_publish(exchange=EXCHANGE_OUT,
|
||||||
body=json.dumps({'signatureId': body_content['signatureId'],
|
body=json.dumps({'signatureId': body_content['signatureId'],
|
||||||
'signatureZoneIndex': body_content['signatureZoneIndex'],
|
'signatureZoneIndex': body_content['signatureZoneIndex'],
|
||||||
|
'byUserId': body_content['byUserId'] if 'byUserId' in body_content else None,
|
||||||
'content': base64.b64encode(signed.read()).decode('utf-8')}),
|
'content': base64.b64encode(signed.read()).decode('utf-8')}),
|
||||||
properties=pika.BasicProperties(content_type='application/json',
|
properties=pika.BasicProperties(content_type='application/json',
|
||||||
delivery_mode=pika.DeliveryMode.Transient),
|
delivery_mode=pika.DeliveryMode.Transient),
|
||||||
|
|||||||
Reference in New Issue
Block a user