from datetime import timedelta

from prefect import flow, task
from prefect.filesystems import LocalFileSystem
from prefect.serializers import JSONSerializer
from prefect.tasks import task_input_hash


@flow(name="sdfsdf")
def main():
    tas1()


@task(
    name="1",
    cache_key_fn=task_input_hash,
    cache_expiration=timedelta(minutes=5),
    persist_result=True,
    result_storage=LocalFileSystem(base_path=".strage-Temp"),
    result_serializer=JSONSerializer(jsonlib="json"),
)
def tas1():
    raise 1 / 0


if __name__ == "__main__":
    main()