diff --git a/tiled/adapters/csv.py b/tiled/adapters/csv.py index ce7f3fc89..88e118594 100644 --- a/tiled/adapters/csv.py +++ b/tiled/adapters/csv.py @@ -372,7 +372,7 @@ def from_assets( # Load the array lazily with Dask file_paths = [path_from_uri(ast.data_uri) for ast in assets] - ddf = dask.dataframe.read_csv(file_paths, **kwargs) + ddf = dask.dataframe.read_csv(file_paths, dtype=structure.data_type.to_numpy_dtype(), **kwargs) if isinstance(structure.data_type, StructDtype): # Expecting a records array