Update rabbitmq.py

materialsproject · Mar 4, 2024 · cc37c23 · cc37c23
1 parent 8264462
commit cc37c23
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/maggma/cli/rabbitmq.py b/src/maggma/cli/rabbitmq.py
@@ -136,7 +136,7 @@ def manager(
                 if not chunk_dict["distributed"]:
                     temp_builder_dict = dict(**builder_dict)
                     temp_builder_dict.update(chunk_dict["chunk"])  # type: ignore
-                    temp_builder_dict = jsanitize(temp_builder_dict)
+                    temp_builder_dict = jsanitize(temp_builder_dict, recursive_msonable=True)
 
                     # Send work for available workers
                     for identity in workers: