in srf-longrun-job-dataflow/srflongrunjobdataflow.py [0:0]
def destination(element): return json.loads(element)["filename"]