Update run.py
Browse files
run.py
CHANGED
@@ -76,13 +76,9 @@ if __name__ == "__main__":
|
|
76 |
data = {"id": 0, "question": "What is the capital of France?"} # This can be a list of samples
|
77 |
# data = {"id": 0, "question": "Who was the NBA champion in 2023?"} # This can be a list of samples
|
78 |
|
79 |
-
|
80 |
-
input_message = FlowMessage(
|
81 |
-
data=data,
|
82 |
-
)
|
83 |
-
|
84 |
#option2: use the proxy_flow
|
85 |
-
|
86 |
|
87 |
#7. ~~~ Run inference ~~~
|
88 |
future = proxy_flow.get_reply_future(input_message)
|
|
|
76 |
data = {"id": 0, "question": "What is the capital of France?"} # This can be a list of samples
|
77 |
# data = {"id": 0, "question": "Who was the NBA champion in 2023?"} # This can be a list of samples
|
78 |
|
79 |
+
|
|
|
|
|
|
|
|
|
80 |
#option2: use the proxy_flow
|
81 |
+
input_message = proxy_flow.package_input_message(data = data)
|
82 |
|
83 |
#7. ~~~ Run inference ~~~
|
84 |
future = proxy_flow.get_reply_future(input_message)
|