Christian
06/09/2020, 8:53 PMJim Crist-Harif
06/09/2020, 8:56 PMChristian
06/09/2020, 9:00 PMJim Crist-Harif
06/09/2020, 9:02 PMDataContext.run_validation_operator
.Christian
06/09/2020, 9:12 PMwith Flow("great expectations example flow") as flow:
checkpoint_name = Parameter("checkpoint_name")
validations = ge_task.map(checkpoint_name)
print("Result:", validations.result)
but the print returns None. Maybe that's due to the use of map() ?Jim Crist-Harif
06/09/2020, 9:18 PMwith Flow(...)
block. At this point no tasks have run, you're just describing the flow you'd like to run later.
⢠Flow run. This happens locally when you call flow.run
, but can also happen if you register a flow to run later with either cloud or server.
To access the results after a run, look at:
state = flow.run()
print(state.result[validations].result)
If you want to add a task after the GE task to handle the output, you can add another task to the flow and pass the results directly:
@task
def handle_ge_output(result):
# do your stuff here
with Flow("great expectations example flow") as flow:
checkpoint_name = Parameter("checkpoint_name")
validations = ge_task.map(checkpoint_name)
handle_ge_output.map(validations)
Christian
06/09/2020, 9:21 PMJim Crist-Harif
06/09/2020, 9:22 PMChristian
06/09/2020, 9:22 PM