Update distributed.py

materialsproject · Mar 4, 2024 · 844b309 · 844b309
1 parent 52508ac
commit 844b309
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/maggma/cli/distributed.py b/src/maggma/cli/distributed.py
@@ -135,7 +135,7 @@ def manager(url: str, port: int, builders: List[Builder], num_chunks: int, num_w
                 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: