snorkelflow.client.operators.execute_operators

warning

This is a beta function in 25.4. Beta features may have known gaps or bugs, but are functional workflows and eligible for Snorkel Support. To access beta features, contact Snorkel Support to enable the feature flag for your Snorkel-hosted instance.

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

Name	Type	Default	Info
df	DataFrame		Pandas dataframe to execute operators over.
processor_config	Optional[List[Dict[str, Any]]]	None	Processor config to execute.
workflow_config	Optional[Dict[int, Any]]	None	Workflow config dict to execute.
return_outputs	bool	False	Whether 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.

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]