Skip to content

Commit 6acce1d

Browse files
committed
[#130] Update black and run new version
1 parent e8db991 commit 6acce1d

File tree

1 file changed

+16
-10
lines changed

1 file changed

+16
-10
lines changed

hlink/linking/matching/link_step_explode.py

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -115,26 +115,32 @@ def _explode(self, df, comparisons, comparison_features, blocking, id_column, is
115115
expand_length = exploding_column["expand_length"]
116116
derived_from_column = exploding_column["derived_from"]
117117
explode_selects = [
118-
explode(self._expand(derived_from_column, expand_length)).alias(
119-
exploding_column_name
118+
(
119+
explode(self._expand(derived_from_column, expand_length)).alias(
120+
exploding_column_name
121+
)
122+
if exploding_column_name == column
123+
else column
120124
)
121-
if exploding_column_name == column
122-
else column
123125
for column in all_column_names
124126
]
125127
else:
126128
explode_selects = [
127-
explode(col(exploding_column_name)).alias(exploding_column_name)
128-
if exploding_column_name == c
129-
else c
129+
(
130+
explode(col(exploding_column_name)).alias(exploding_column_name)
131+
if exploding_column_name == c
132+
else c
133+
)
130134
for c in all_column_names
131135
]
132136
if "dataset" in exploding_column:
133137
derived_from_column = exploding_column["derived_from"]
134138
explode_selects_with_derived_column = [
135-
col(derived_from_column).alias(exploding_column_name)
136-
if exploding_column_name == column
137-
else column
139+
(
140+
col(derived_from_column).alias(exploding_column_name)
141+
if exploding_column_name == column
142+
else column
143+
)
138144
for column in all_column_names
139145
]
140146
if exploding_column["dataset"] == "a":

0 commit comments

Comments
 (0)