snorkelflow.client.workflows.execute_prediction_api

snorkelflow.client.workflows.execute_prediction_api(client, df, return_outputs=False)

Execute an exported workflow running via Prediction API on a new Pandas DataFrame.

Parameters

Parameters

Name	Type	Default	Info
client	HTTPClient		SnorkelFlowPredictionAPIClient object.
df	DataFrame		Data over which to execute the workflow.
return_outputs	bool	False	Whether to return workflow output as a dictionary of output names to dataframes. If False, assumes there is only one output in the workflow and directly returns the corresponding the dataframe.

Returns

Returns

Dictionary mapping outputs in Workflow DAG to corresponding Pandas DataFrame. If return_outputs is False, assumes there is only 1 output, and returns the corresponding dataframe.

Return type

Return type

Dict(str, pandas.DataFrame) or pandas.DataFrame