Bob Colner
07/02/2020, 9:58 PMDylan
07/02/2020, 10:06 PMBob Colner
07/02/2020, 10:07 PMDylan
07/02/2020, 10:08 PMBob Colner
07/02/2020, 10:09 PMDylan
07/02/2020, 10:09 PM@task(target="{param}/file.txt")
def my_task(param):
pass
Should work on Prefect version 0.12.0 and aboveMarvin
07/02/2020, 10:11 PMBob Colner
07/02/2020, 10:11 PMDylan
07/02/2020, 10:12 PMBob Colner
07/02/2020, 10:12 PMDylan
07/02/2020, 10:13 PMBob Colner
07/02/2020, 10:15 PMDylan
07/02/2020, 10:40 PMBob Colner
07/02/2020, 10:44 PMclass MySerializer(prefect.engine.serializers.Serializer):
def serialize(self, value: Any) -> bytes:
# transform a Python object into bytes
pass
def deserialize(self, value: Union[bytes, str]) -> Any:
# recover a Python object from bytes
pass