Skip to content

Commit 144dd30

Browse files
committed
Lint corrections
1 parent 4f5ebb4 commit 144dd30

File tree

2 files changed

+12
-14
lines changed

2 files changed

+12
-14
lines changed

bigml/pipeline.py

+11-13
Original file line numberDiff line numberDiff line change
@@ -101,6 +101,15 @@ def check_in_path(path, resource_list):
101101
return True
102102

103103

104+
def merge_input_data(input_data_list, output_data_list):
105+
"""Adding input data to the output """
106+
for index, input_data in enumerate(input_data_list):
107+
for key, value in input_data.items():
108+
if key not in output_data_list[index]:
109+
output_data_list[index].update({key: value})
110+
return output_data_list
111+
112+
104113
class Transformer():
105114
"""Base class to handle transformations. It offers a transform method
106115
that can handle list of dictionaries or Pandas DataFrames a inputs and
@@ -190,14 +199,6 @@ def data_transform(self, input_data_list):
190199
The input list is expected to be a list of dictionaries"""
191200
return self.generator(input_data_list)
192201

193-
def merge_input_data(self, input_data_list, output_data_list):
194-
"""Adding input data to the output """
195-
for index, input_data in enumerate(input_data_list):
196-
for key, value in input_data.items():
197-
if key not in output_data_list[index]:
198-
output_data_list[index].update({key: value})
199-
return output_data_list
200-
201202

202203
class DFTransformer(Transformer):
203204
"""Transformer wrapper for DataFrames """
@@ -321,11 +322,7 @@ def data_transform(self, input_data_list):
321322
result = DataFrame(result, **df_kwargs)
322323
if not self.add_input:
323324
return result
324-
return self.merge_input_data(input_data_list, result)
325-
326-
def merge_input_data(self, input_data_list, output_data_list):
327-
"""Merging the original input data with the output """
328-
return concat([input_data_list, output_data_list], axis=1)
325+
return concat([input_data_list, result], axis=1)
329326

330327

331328
class Pipeline(Transformer):
@@ -644,3 +641,4 @@ def load(cls, name, dump_dir):
644641
return cls(name,
645642
None,
646643
cache_get=fs_cache_get(dump_dir))
644+
return None

bigml/util.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -423,7 +423,7 @@ def cast(input_data, fields):
423423
if key not in fields:
424424
continue
425425
# strings given as booleans
426-
elif isinstance(value, bool) and \
426+
if isinstance(value, bool) and \
427427
fields[key]['optype'] == 'categorical' and \
428428
len(fields[key]['summary']['categories']) == 2:
429429
try:

0 commit comments

Comments
 (0)