    def from_pipeline(fn):
        """Create an Action for callable op.

        Args:
            fn (callable): The callable function for op.

        Returns:
            Action: The action.
        """
        action = OperatorAction()
        action._dag_dict = fn.dag_repr.dag_dict
        action._top_sort = fn.dag_repr.top_sort
        action._type = OPType.PIPELINE
        return action
Create an Action for callable op.

Args:
fn (callable): The callable function for op.

Returns:
Action: The action.
towhee/runtime/operator_manager/operator_action.py