from prefect import task, Flow
import prefect
import random

from multiprocessing.dummy import Pool as ThreadPool

@task
def random_number():
    return random.randint(0, 100)

def plus_one_f(x):
    prefect.context.get("logger").info(f"Plus One F : {x}")
    return x+1

@task
def plus_one(x):
    a = plus_one_f(x)
    with ThreadPool(8) as pool:
        results = pool.map(plus_one_f, [x])

with Flow('My Functional Flow') as flow:
    r = random_number()
    y = plus_one(x=r)

flow.run()