diff --git a/decoder.py b/decoder.py index 334a070..3edf2cf 100644 --- a/decoder.py +++ b/decoder.py @@ -53,7 +53,7 @@ def decode_j1939_frames(df: pl.DataFrame) -> pl.DataFrame: da = pl.when(pf < 240).then(ps).otherwise(255) pgn = pl.when(pf < 240).then((id_int // 256) % 65536).otherwise((id_int // 256) % 262144) - j1939_meta = pl.when(is_j1939).then( + pl.when(is_j1939).then( pl.struct([ priority.cast(pl.UInt8).alias("Priority"), pf.cast(pl.UInt8).alias("PF"),