Can you dynamically load flyte tasks to run inside of a dynamic task? e.g. if I want a task to act as a wrapper

@dynamic
def rerun():
    relative_func = "flyte.tasks.example_task"
    relative_mod, input_func = relative_func.rsplit(".", 1)
    import_mod = importlib.import_module(relative_mod)
    rerun_task = getattr(import_mod, input_func)
    inputs = [SOME STUFF]
    map_task(rerun_task, concurrency=8)(input=inputs)

getting errors like

File "/usr/local/lib/python3.9/site-packages/flytekit/core/tracker.py", line 229, in extract_task_module
        name = f.lhs
      File "/usr/local/lib/python3.9/site-packages/flytekit/core/tracker.py", line 70, in lhs
        return self.find_lhs()
      File "/usr/local/lib/python3.9/site-packages/flytekit/core/tracker.py", line 96, in find_lhs
        raise _system_exceptions.FlyteSystemException(f"Error looking for LHS in {self._instantiated_in}")

Message:

    Error looking for LHS in __main__

I think it’s possible, might need some changes in flytekit. why don’t import task directly, like

from relative_mod import input_func

bc the task is a user import so I wouldn't know what it is until it runs

ohh, I see, module name will be the task input. mind create an issue here, I think we need make some small changes in flytekit. [flyte-bug]

🐞 Create a new Flyte Bug issue: https://github.com/flyteorg/flyte/issues/new?assignees=&labels=bug%2Cuntriaged&template=bug_report.yaml&title=%5BBUG%5D+