Skip to content

Commit a41cfe6

Browse files
committed
[SYSTEMDS-3548] Update converters.py to be black compliant
1 parent 8323515 commit a41cfe6

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/main/python/systemds/utils/converters.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -101,10 +101,8 @@ def convert_column(jvm, rows, j, col_type, pd_col):
101101
col_data = pd_col.fillna("").to_numpy()
102102
byte_data = bytearray(col_data.tobytes())
103103

104-
converted_array = (
105-
jvm.org.apache.sysds.runtime.util.Py4jConverterUtils.convert(
106-
byte_data, rows, col_type
107-
)
104+
converted_array = jvm.org.apache.sysds.runtime.util.Py4jConverterUtils.convert(
105+
byte_data, rows, col_type
108106
)
109107
return j, converted_array
110108

@@ -161,7 +159,9 @@ def pandas_to_frame_block(sds, pd_df: pd.DataFrame):
161159

162160
with concurrent.futures.ThreadPoolExecutor() as executor:
163161
futures = [
164-
executor.submit(convert_column, jvm, rows, j, schema[j], pd_df[col_name])
162+
executor.submit(
163+
convert_column, jvm, rows, j, schema[j], pd_df[col_name]
164+
)
165165
for j, col_name in enumerate(col_names)
166166
]
167167
for future in concurrent.futures.as_completed(futures):

0 commit comments

Comments
 (0)