0.15.1

from prefect import task, Flow
from prefect.executors import LocalDaskExecutor
from prefect.storage import Docker
from prefect.run_configs import LocalRun, DockerRun

from research.example_pkg import things

@task()
def run_thing1():
    if things.thing1():
        return True

@task()
def run_thing2():
    if things.thing2():
        return True

if __name__ == "__main__":
    with Flow("test_flow", executor=LocalDaskExecutor(scheduler="processes")) as flow:
        if run_thing1():
            thing2_var = run_thing2()

    flow.run_config = LocalRun(
        env={
            "PREFECT__LOGGING__LEVEL": "DEBUG",
            "PREFECT__LOGGING__EXTRA_LOGGERS": '["research"]'
        }
    )
    flow.run()

PREFECT__LOGGING__EXTRA_LOGGERS='["research"]'