Commit fe37e1ad authored by 赵威's avatar 赵威

Merge branch 'fe' into 'offic'

change prediction size

See merge request !10
parents 727394da f9425c62
......@@ -20,7 +20,7 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
consumer.poll()
consumer.seek_to_end()
predict_size = 200
predict_size = 250
try:
for msg in consumer:
......
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