diff --git a/great_ai/utilities/parallel_map/mapper_function.py b/great_ai/utilities/parallel_map/mapper_function.py index cc4e57b..1aa4721 100644 --- a/great_ai/utilities/parallel_map/mapper_function.py +++ b/great_ai/utilities/parallel_map/mapper_function.py @@ -43,7 +43,11 @@ def mapper_function( ), ) except Exception as e: - return MapResult(i, None, e, traceback.format_exc()) + # `e` has to be stringified in order to avoid any + # surprising serialization error when returning it + return MapResult( + i, None, str(e), traceback.format_exc() + ) async def main() -> List[MapResult]: return await asyncio.gather(