[sheet-service] add ref
This commit is contained in:
parent
d614aef5f0
commit
227ee756f4
1 changed files with 5 additions and 1 deletions
6
main.py
6
main.py
|
|
@ -340,6 +340,7 @@ def redis_message_handler():
|
|||
"from": SERVICE_NAME,
|
||||
"level": "content",
|
||||
"to": user_id,
|
||||
"ref": "catalog",
|
||||
"content": result
|
||||
}
|
||||
}
|
||||
|
|
@ -541,7 +542,8 @@ def send_stream_notification(msg_type: str, content: any, batch_id: str, current
|
|||
"current_chunk": current_chunk,
|
||||
"total_chunks": total_chunks,
|
||||
"total_items": total_items,
|
||||
"to": user_id,
|
||||
"to": user_id,
|
||||
"ref": "catalog",
|
||||
"content": content
|
||||
}
|
||||
}
|
||||
|
|
@ -1638,6 +1640,7 @@ def handle_get_price(country: str, user_id: str, content: list):
|
|||
"from": SERVICE_NAME,
|
||||
"level": "content",
|
||||
"to": user_id,
|
||||
"ref": "price",
|
||||
"content": result
|
||||
}
|
||||
}
|
||||
|
|
@ -1667,6 +1670,7 @@ def handle_get_price(country: str, user_id: str, content: list):
|
|||
"from": SERVICE_NAME,
|
||||
"level": "content",
|
||||
"to": user_id,
|
||||
"ref": "price",
|
||||
"content": {"error": str(e)}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue