Skip to content

Commit bdea4d1

Browse files
committed
Consistent decimal scale in polars
1 parent fa3ea44 commit bdea4d1

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

src/alhambra_mixes/actions.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,7 @@ def all_components_polars(
291291
r = _ratio(dc, sc)
292292
if math.isnan(r):
293293
r = None
294-
comps = comps.with_columns(pl.col("concentration_nM").mul(r))
294+
comps = comps.with_columns(pl.col("concentration_nM").mul(r).cast(pl.Decimal(scale=6)))
295295

296296
all_comps.append(comps)
297297

src/alhambra_mixes/components.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ def all_components_polars(self, _cache_key=None) -> pl.DataFrame:
186186
},
187187
schema={
188188
'name': pl.String,
189-
'concentration_nM': pl.Decimal(precision=20, scale=6),
189+
'concentration_nM': pl.Decimal(scale=6),
190190
'component': pl.Object
191191
}
192192
)

src/alhambra_mixes/mixes.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -522,7 +522,7 @@ def all_components_polars(self, _cache_key=None) -> pl.DataFrame:
522522
pl.when(pl.col("concentration_nM").is_null().any())
523523
.then(pl.lit(None))
524524
.otherwise(pl.col("concentration_nM").sum())
525-
.alias("concentration_nM"),
525+
.alias("concentration_nM").cast(pl.Decimal(scale=6)),
526526
pl.col("component").first(), # FIXME
527527
)
528528

0 commit comments

Comments
 (0)