Trevor Kramer
03/27/2021, 6:59 PM@task()
def get_s3_location(workspace_bucket):
return f's3://{workspace_bucket}/{prefect.context.get("flow_run_name")}/'
Something like the simple addition prefect turns into tasks automatically within the flow?Chris White
get_s3_location = task(lambda workspace_bucket: f's3://{workspace_bucket}/{prefect.context.get("flow_run_name")}/', name='get_s3_location')
but I’m not sure that’s any better