Brett Naul
03/16/2022, 2:11 PMprefect.engine.signals.FAIL: Flow finished in state <Failed: "Failed to load and execute flow run: FlowStorageError('An error occurred while unpickling the flow:\n AttributeError("\'Comment\' object has no attribute \'_end\'")')">
the flows are stored in GCS, python is 3.9.10 both locally (MacOS) and remote (docker+k8s). same prefect+cloudpickle versions. I've had the same thing happen before when python versions don't match but bumping has always fixed it, not really sure what else to look into now. any suggestions...?Kevin Kho
03/16/2022, 2:13 PMComment
is a custom class?Brett Naul
03/16/2022, 2:14 PMComment
https://github.com/pytorch/pytorch/issues/59777Kevin Kho
03/16/2022, 2:17 PMAnna Geller
03/16/2022, 2:40 PMBrett Naul
03/16/2022, 2:42 PMidempotency_key=flow.serialized_hash()
) might have fixed; I'll probably add some version strings to the hash to prevent this collision in the future. still puzzled though that no version mismatch errors are bubbling upAnna Geller
03/16/2022, 2:45 PMBrett Naul
03/16/2022, 4:06 PMprefect.Client().register(flow, idempotency_key=flow.serialized_hash())