diff --git a/src/maggma/cli/distributed.py b/src/maggma/cli/distributed.py index 78170b323..e1aa0f07c 100644 --- 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: