RunGreatExpectationsValidation 执行 returns 异常

Question

我正在努力解决 great_expectations 集成问题。
我显然使用 RunGreatExpectationsValidation 任务：

validation_task = RunGreatExpectationsValidation()
with Flow(
    "GE_pull_and_run",
) as GE_pull_and_run_flow:
    .......
    validation_task(
        context_root_dir=root_dir,
        checkpoint_name=expectation_checkpoint_name
    )

当我运行 GE 上的命令（great_expectations --V3-api 检查点运行 my_checkpoint）时，它有效，但在 prefect任务，我有一个例外：使用 GE V3 api:

    .....
   File "c:\Users\vincent2\DK\prefect.data.pipeline\venv\lib\site- 
   packages\prefect\tasks\great_expectations\checkpoints.py", line 246, in run
        for batch in ge_checkpoint["batches"]:
    TypeError: 'Checkpoint' object is not subscriptable

与GE V2相同api

    ...
        for batch in ge_checkpoint["batches"]:
    TypeError: 'LegacyCheckpoint' object is not subscriptable

Great_expectations=0.13.43（也尝试过 0.12.10 版本）
知府=0.15.9
有人经历过这个铅吗？谢谢

Answer 1

提供更新：此问题已作为 this PR in Prefect 的一部分得到修复。现在就随意尝试一下，如果仍然有什么不适合您，请告诉我们。

RunGreatExpectationsValidation 执行 returns 异常

RunGreatExpectationsValidation execution returns an exception

great-expectations

prefect