def destination()

in srf-longrun-job-dataflow/srflongrunjobdataflow.py [0:0]


def destination(element):
    return json.loads(element)["filename"]