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
Comment
is a custom class?Brett Naul
03/16/2022, 2:14 PMComment
https://github.com/pytorch/pytorch/issues/59777Brett Naul
03/16/2022, 2:16 PMKevin Kho
Anna Geller
Brett 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
Brett Naul
03/16/2022, 4:06 PMprefect.Client().register(flow, idempotency_key=flow.serialized_hash())