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
@ymtricks
ymtricks / test_apps.py
Created May 26, 2026 11:02
fal KV store propagation
# ---- server.py ----
import os
from time import sleep
from typing import Literal
from uuid import UUID
import fal
from fal.toolkit.kv import KVStore
from pydantic import BaseModel, Field