obsei commited on
Commit
2d55fb8
1 Parent(s): 2697814

Show Pandas df

Browse files
Files changed (1) hide show
  1. utils.py +3 -1
utils.py CHANGED
@@ -200,7 +200,9 @@ def execute_workflow(generate_config, component=None, log_components=None):
200
  log_components["analyzer"].write([vars(response) for response in analyzer_response_list])
201
 
202
  sink_response_list = sink.send_data(analyzer_response_list, sink_config)
203
- if sink_response_list:
 
 
204
  log_components["sink"].write([vars(response) for response in sink_response_list])
205
  else:
206
  log_components["sink"].write("No Data")
200
  log_components["analyzer"].write([vars(response) for response in analyzer_response_list])
201
 
202
  sink_response_list = sink.send_data(analyzer_response_list, sink_config)
203
+ if sink.TYPE == 'Pandas':
204
+ log_components["sink"].write(sink_response_list)
205
+ elif sink_response_list is not None:
206
  log_components["sink"].write([vars(response) for response in sink_response_list])
207
  else:
208
  log_components["sink"].write("No Data")