0

私は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 checkpoint run my_checkpoint)、機能しますが、完全なタスクでは例外があります: 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 でも試しました)
prefect=0.15.9
この pb を経験した人はいますか? ありがとう

4

1 に答える 1