Kevin Weiler
07/14/2021, 9:17 PMextra_loggers
config at the level of my flow (as described here) but it’s not having the desired effect (logging stuff from my imported code)Kevin Weiler
07/14/2021, 9:18 PM0.15.1
Kevin Weiler
07/14/2021, 9:19 PMfrom 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()
Kevin Weiler
07/14/2021, 9:20 PMKevin Weiler
07/14/2021, 9:20 PMPREFECT__LOGGING__EXTRA_LOGGERS='["research"]'
Kevin Weiler
07/14/2021, 9:20 PMKevin Weiler
07/14/2021, 9:20 PMKevin Kho
"['research']"
instead? double quotes on the outside.