def process()

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

• 7 lines of code
• 1 McCabe index (conditional complexity)

    def process(self, element):
        x = uuid.uuid4()
        record = json.loads(element)
        file_name = record['filename'].split("/")
        writer = filesystems.FileSystems.create(self.outdir + file_name[-1] + "_" + str(x)[:8] + ".json")
        writer.write(json.dumps(record).encode("utf8"))
        writer.close()