change prediction size

f9425c62 · 赵威 · d8ead533 · f9425c62
Commit f9425c62 authored Aug 27, 2020 by 赵威
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

online_prediction.py src/online_prediction.py +1 -1

No files found.
--- a/src/online_prediction.py
+++ b/src/online_prediction.py
@@ -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: