python
from taskflow import engines
from taskflow.patterns import linear_flow
from taskflow.task import Task
class PrintTask(Task):
def execute(self, *args, **kwargs):
for value in args:
print(value)
flow = linear_flow.Flow("my_flow")
flow.add(PrintTask("print_task"))
engine = engines.load(flow)
engine.run()
