update prediction size

9ae51816 · 赵威 · a4e88025 · 9ae51816
Commit 9ae51816 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 = 300
+    predict_size = 200

    try:
        for msg in consumer: