私は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 を経験した人はいますか? ありがとう