Skip to content

Commit aa880c1

Browse files
committed
fix _right suffixed join columns
1 parent 7c95706 commit aa880c1

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

xifdr/fdr.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,7 @@ def full_fdr(df: Union[pl.DataFrame, pd.DataFrame],
155155
df_ppi.select(*ppi_cols, *pass_on_cols),
156156
on=ppi_cols,
157157
how='full',
158+
coalesce=True,
158159
).with_columns(
159160
pass_threshold=pl.col('pass_threshold').fill_null(pl.lit(False))
160161
)
@@ -164,6 +165,7 @@ def full_fdr(df: Union[pl.DataFrame, pd.DataFrame],
164165
df_link.select(*link_cols, *pass_on_cols),
165166
on=link_cols,
166167
how='full',
168+
coalesce=True,
167169
).with_columns(
168170
pass_threshold=pl.col('pass_threshold').fill_null(pl.lit(False))
169171
)
@@ -173,6 +175,7 @@ def full_fdr(df: Union[pl.DataFrame, pd.DataFrame],
173175
df_pep.select(*pep_cols, *pass_on_cols),
174176
on=pep_cols,
175177
how='full',
178+
coalesce=True,
176179
).with_columns(
177180
pass_threshold=pl.col('pass_threshold').fill_null(pl.lit(False))
178181
)

0 commit comments

Comments
 (0)