Isara Ovin
06/28/2022, 8:41 AMzsh: segmentation fault python app.py
when im trying to run a flow using LocalDaskExecutor
using threads can someone please helpwith Flow("local-reader", executor=LocalDaskExecutor(scheduler="threads")) as flow:
directory = Parameter('directory', required=True)
path_list = locate_local_files(directory)
data = local_file_reader.map(path_list)
output = filter_empty_responses(data)
Kevin Kho
06/28/2022, 3:11 PMIsara Ovin
06/30/2022, 3:00 PMflow.run()
around if __name__ == "__main__":
solved this without doing any changes