Version: 0.91

snorkelflow.client.workflows.execute_workflow

snorkelflow.client.workflows.execute_workflow(df, workflow_uid, monitor=False, return_outputs=False)

Execute an exported workflow running on a Snorkel Flow development instance on a new Pandas DataFrame.

Deprecated since version 2024.R1: Use Deployment.execute instead.

Parameters Parameters
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

Name	Type	Default	Info
df	`DataFrame`		Data over which to execute the workflow.
workflow_uid	`int`		UID of the workflow to execute.
monitor	`bool`	`False`	Whether to store the monitoring data. Default is set to False.
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.