davzucky
07/22/2022, 6:01 AMAnna Geller
07/22/2022, 9:40 AMfrom prefect import task, flow
from prefect import get_run_logger
from prefect.deployments import Deployment
from prefect.packaging import FilePackager
from prefect.filesystems import RemoteFileSystem
@task
def say_hi(user_name: str):
logger = get_run_logger()
<http://logger.info|logger.info>("Hello %s!", user_name)
@flow
def hello(user: str = "world"):
say_hi(user)
Deployment(
flow=hello,
name="s3_file_packager_with_remote_s3fs",
packager=FilePackager(
filesystem=RemoteFileSystem(basepath="<s3://prefect-orion/flows/>")
),
)
if you can't set up your endpoint properly with settings on RemoteFileSystem, please LMK and I'll open an issuedavzucky
07/22/2022, 11:08 AM