Skip to content

Commit c084e74

Browse files
committed
Fix python style.
1 parent d206b7c commit c084e74

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

python/pyspark/worker.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -100,17 +100,18 @@ def verify_result_length(*a):
100100
try:
101101
arrow_type_of_result = pa.from_numpy_dtype(result.dtype)
102102
both_are_timestamp = pa.types.is_timestamp(arrow_type_of_result) and \
103-
pa.types.is_timestamp(arrow_return_type)
103+
pa.types.is_timestamp(arrow_return_type)
104104
if not both_are_timestamp and arrow_return_type != arrow_type_of_result:
105105
print("WARN: Arrow type %s of return Pandas.Series of the user-defined function's "
106106
"dtype %s doesn't match the arrow type %s "
107107
"of defined return type %s" % (arrow_type_of_result, result.dtype,
108108
arrow_return_type, return_type),
109109
file=sys.stderr)
110110
except:
111-
print("WARN: Can't infer arrow type of Pandas.Series's dtype: %s, which might not match "
112-
"the arrow type %s of defined return type %s" % (result.dtype, arrow_return_type,
113-
return_type),
111+
print("WARN: Can't infer arrow type of Pandas.Series's dtype: %s, which might not "
112+
"match the arrow type %s of defined return type %s" % (result.dtype,
113+
arrow_return_type,
114+
return_type),
114115
file=sys.stderr)
115116

116117
return result

0 commit comments

Comments
 (0)