Ben Fogelson
09/24/2020, 4:50 PMResult
instance or a raw value? The functionality I’m looking for is basically this:
@task
def foo(bar):
if isinstance(bar, Result):
bar = bar.read(bar.location).value
return do_something(bar)
Clearly the above isn’t hard to add, but it also seems like the kind of thing where (a) there might be hidden gotchas and (b) it seems common enough that prefect
might have something built inDylan
Result
unpacking for you under the hood. Are you trying to explicitly pass a Result
class?Ben Fogelson
09/24/2020, 4:59 PMGCSResult
class). Flow B has a parameter that it expects to be a dataframe. It would be nice if the parameter for Flow B could be either a raw dataframe or some pointer to the location in gcs that prefect automatically unpacks into a dataframeDylan
Ben Fogelson
09/28/2020, 3:45 PMDylan
Ben Fogelson
09/28/2020, 4:01 PM