snorkelflow.client.operators.execute_operators
- snorkelflow.client.operators.execute_operators(df, processor_config=None, workflow_config=None, return_outputs=False)
Execute a series of operators from a given dataframe, and either a processor_config or a workflow_config.
Parameters
Parameters
Returns
Returns
Returns a dictionary of output names to pandas DataFrames that were computed from the processor_config being run over the input_df. If return_outputs is False, returns the dataframe corresponding to the last output in the workflow.
Return type
Return type
Union[Dict[str, pd.DataFrame], pd.DataFrame]
Name Type Default Info df DataFramePandas dataframe to execute operators over. processor_config Optional[List[Dict[str, Any]]]NoneProcessor config to execute. workflow_config Optional[Dict[int, Any]]NoneWorkflow config dict to execute. return_outputs boolFalseWhether to return workflow output as a dictionary of output names to dataframes. If False, returns the dataframe corresponding to the last output in the workflow.