DiffyBron
12/08/2019, 1:52 PMJenny
12/08/2019, 2:07 PMDiffyBron
12/08/2019, 2:35 PMpython test.py
from prefect import Flow, Parameter, task
from prefect.tasks.control_flow import ifelse
@task
def check_if_even(value):
return (value % 2 == 0)
@task
def print_even(value):
print("{} is even".format(value))
@task
def print_odd(value):
print("{} is even".format(value))
if __name__ == '__main__':
with Flow("Check even or odd") as flow:
value = Parameter("value")
is_even = check_if_even(value)
even = print_even(value)
odd = print_odd(value)
ifelse(is_even, even, odd)
flow.run(value=5)
flow.run(value=4)
My ideal output should be the following with TaskRunner logs omitted, what can i do to achieve that?
5 is even
4 is even
Jenny
12/08/2019, 2:47 PMDiffyBron
12/08/2019, 3:07 PM[2019-12-08 15:05:46,055] INFO - prefect.FlowRunner | Beginning Flow run for 'Check even or odd'
[2019-12-08 15:05:46,056] INFO - prefect.FlowRunner | Starting flow run.
[2019-12-08 15:05:46,062] INFO - prefect.TaskRunner | Task 'value': Starting task run...
[2019-12-08 15:05:46,064] INFO - prefect.TaskRunner | Task 'value': finished task run for task with final state: 'Success'
[2019-12-08 15:05:46,070] INFO - prefect.TaskRunner | Task 'check_if_even': Starting task run...
[2019-12-08 15:05:46,072] INFO - prefect.TaskRunner | Task 'check_if_even': finished task run for task with final state: 'Success'
[2019-12-08 15:05:46,078] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': Starting task run...
[2019-12-08 15:05:46,080] INFO - prefect.TaskRunner | Task 'CompareValue: "False"': finished task run for task with final state: 'Success'
5 is even
Jeremiah
12/08/2019, 3:38 PMimport logging
logging.getLogger("prefect").setLevel(0)
DiffyBron
12/08/2019, 3:40 PMJeremiah
12/08/2019, 3:41 PMDiffyBron
12/08/2019, 3:45 PMimport os
os.environ['PREFECT__LOGGING__LEVEL'] = 'WARNING'
Jeremiah
12/08/2019, 3:47 PMos.environ
directly, I’d expect that to work as long as you imported Prefect for the first time after that assignmentChris White
12/08/2019, 5:14 PMJeremiah
12/08/2019, 5:15 PMos.environ
dict, so I would have thought that subsequent imports would “work”Jenny
12/08/2019, 5:21 PMexport PREFECT__LOGGING__LEVEL="WARNING"
should work.DiffyBron
12/08/2019, 5:36 PMos.environment
Jenny
12/08/2019, 6:03 PMDiffyBron
12/09/2019, 3:16 AM