Update kafka for publisher

NSLS-II-XPD · Feb 26, 2024 · 908a12f · 908a12f
1 parent b39c93c
commit 908a12f
Show file tree

Hide file tree

Showing 17 changed files with 386 additions and 1 deletion.
diff --git a/scripts/kafka_consumer_publisher.py b/scripts/kafka_consumer_publisher.py
diff --git a/scripts/DEBUSSY_plot_01.ipynb → scripts/notes/DEBUSSY_plot_01.ipynb b/scripts/DEBUSSY_plot_01.ipynb → scripts/notes/DEBUSSY_plot_01.ipynb
diff --git a/scripts/qserver_zmq_001.ipynb → scripts/notes/qserver_zmq_001.ipynb b/scripts/qserver_zmq_001.ipynb → scripts/notes/qserver_zmq_001.ipynb
diff --git a/scripts/read_db_catalog.ipynb → scripts/notes/read_db_catalog.ipynb b/scripts/read_db_catalog.ipynb → scripts/notes/read_db_catalog.ipynb
diff --git a/scripts/prepare_agent.py b/scripts/prepare_agent.py
@@ -30,7 +30,7 @@ def build_agen(peak_target=660, peak_tolerance=5):
 
 
     dofs = [
-        DOF(description="CsPb(oleate)3", name="infusion_rate_CsPb", units="uL/min", search_bounds=(10, 110)),
+        DOF(description="CsPb(oleate)3", name="infusion_rate_CsPb", units="uL/min", search_bounds=(2, 110)),
         DOF(description="TOABr", name="infusion_rate_Br", units="uL/min", search_bounds=(50, 200)),
         DOF(description="ZnCl2", name="infusion_rate_Cl", units="uL/min", search_bounds=(0, Cl_up_limit)),
         DOF(description="ZnI2", name="infusion_rate_I2", units="uL/min", search_bounds=(0, I_up_limit)),

diff --git a/scripts/kafka_consumer_single.py → scripts/tests/kafka_consumer_single.py b/scripts/kafka_consumer_single.py → scripts/tests/kafka_consumer_single.py
diff --git a/scripts/kafka_consumer_with_qserver.py → scripts/tests/kafka_consumer_with_qserver.py b/scripts/kafka_consumer_with_qserver.py → scripts/tests/kafka_consumer_with_qserver.py
diff --git a/scripts/kafka_consumer_with_qserver_dummy.py → ...ests/kafka_consumer_with_qserver_dummy.py b/scripts/kafka_consumer_with_qserver_dummy.py → ...ests/kafka_consumer_with_qserver_dummy.py
diff --git a/scripts/print_kafka_with_main.py → scripts/tests/print_kafka_with_main.py b/scripts/print_kafka_with_main.py → scripts/tests/print_kafka_with_main.py
diff --git a/scripts/print_kafka_with_main2.py → scripts/tests/print_kafka_with_main2.py b/scripts/print_kafka_with_main2.py → scripts/tests/print_kafka_with_main2.py
diff --git a/scripts/print_kafka_with_main3.py → scripts/tests/print_kafka_with_main3.py b/scripts/print_kafka_with_main3.py → scripts/tests/print_kafka_with_main3.py
diff --git a/scripts/print_kafka_with_main_consumer.py → ...s/tests/print_kafka_with_main_consumer.py b/scripts/print_kafka_with_main_consumer.py → ...s/tests/print_kafka_with_main_consumer.py
diff --git a/scripts/queue_test_001.py → scripts/tests/queue_test_001.py b/scripts/queue_test_001.py → scripts/tests/queue_test_001.py
diff --git a/scripts/queue_test_002.py → scripts/tests/queue_test_002.py b/scripts/queue_test_002.py → scripts/tests/queue_test_002.py
diff --git a/scripts/queue_test_002_ex.py → scripts/tests/queue_test_002_ex.py b/scripts/queue_test_002_ex.py → scripts/tests/queue_test_002_ex.py
diff --git a/scripts/queue_test_003.py → scripts/tests/queue_test_003.py b/scripts/queue_test_003.py → scripts/tests/queue_test_003.py
diff --git a/scripts/queue_test_004.py → scripts/tests/queue_test_004.py b/scripts/queue_test_004.py → scripts/tests/queue_test_004.py