Increase collector queue size; pin version of markupsafe due to API break

woodlee · woodlee · commit 1c3618a7766f · 2022-09-16T09:51:42.000-05:00
diff --git a/plan_monitor/collect.py b/plan_monitor/collect.py
@@ -86,7 +86,7 @@ def poll_db(db_identifier: str, odbc_conn_string: str, stop_event: mp.Event,
 def collect() -> None:
     kafka_producer = common.build_producer(message_schemas.QUERY_STATS_MESSAGE_KEY_AVRO_SCHEMA,
                                            message_schemas.QUERY_STATS_MESSAGE_VALUE_AVRO_SCHEMA)
-    result_queue = mp.Queue(10000)
+    result_queue = mp.Queue(50000)
     stop_event = mp.Event()
     produced_count = 0
     processes = []
diff --git a/requirements.txt b/requirements.txt
@@ -1,4 +1,5 @@
 confluent-kafka[avro]==1.8.2
+markupsafe==2.0.1
 pyodbc==4.0.32
 python-dateutil==2.8.2
 pytz==2021.3
