https://prefect.io logo
Title
b

Bradley Hurley

12/07/2022, 7:16 PM
Hi Prefect Folks - I am running Prefect 1.x and using Kubernetes Agents with Dask pods to execute tasks. I’ve had the need to create my own
StorageSchema
. Is there a recommended approach to ensuring my custom StorageSchema is globally accessible in the
StorageSchema.type_schemas
? As a workaround we are calling
StorageSchema.type_schemas["MyCustomStorageSchema"] = MyCustomStorageSchema
in our CLI wrapper before creating agents so that the custom schema is accessible, but when we create child flows via Dask workers the custom storage is not set and the flow fails.
1️⃣ 1