Hi 👋, is there a way to pass in a function from a workflow into the subworkflow, and execute the user defined function inside the subworkflow?

Are you trying to dynamically choose a function to execute? There are conditionals that you can use to decide based on a prior step's output or you can use

@dynamic

to run a fully dynamic workflow...

@dynamic
def my_dynamic_wf(inputs...):
 ... call this or that

The dynamic workflow won't immediately call

this

or

that

but instead figure out the workflow graph then execute it after the function returns

Not really, more like

def user_defined_function():
    # do something

@workflow
def subworkflow(custom_function: Any):
    custom_function()
    # do other things

@workflow
def workflow():
    subworkflow(custom_function=user_defined_function)
    # do more things

I get that but I'm trying to uncover what is the purpose of that? Would something like this suffice?

def user_defined_function():
    # do something

@workflow
def subworkflow(custom_function_name: Any):
    conditional("func")._if(custom_function_name == "user_defined_function").then(custom_function())...
    # do other things

@workflow
def workflow():
    subworkflow(custom_function_name="user_defined_function")
    # do more things

Are you trying to build a workflow that others can use and substitute their own implementation for a portion of it?

You can use pickle

what she is trying to do is more like this

@workflow
def workflow_with_udf_input(user_passed_in_func: Type):
  // some logic
  result=user_passed_in_func()

user's perspective

def user_defined_function():

@workflow
def user_invoke_our_workflow():
  // some logic
  workflow_with_udf_input(user_defined_function)

we do not support tasks as parameters today