Skip to content

Instantly share code, notes, and snippets.

@ymtricks
ymtricks / results.py
Created August 15, 2023 08:20
Prefect serializer with async dumps/loads
from io import BytesIO
from typing import Literal, Any
import cloudpickle
import pandas as pd
import prefect
from prefect import flow, task
from prefect.context import TaskRunContext, FlowRunContext
from prefect.filesystems import LocalFileSystem, WritableFileSystem
from prefect.results import get_default_result_storage