I’m trying to implement an example code for land use classification but when I run these lines of code it throws an error of a broken process pool.
%%time
Time interval for the SH request
time_interval = [‘2019-01-01’, ‘2019-12-31’]
Define additional parameters of the workflow
execution_args = []
for idx, bbox in enumerate(bbox_list[patchIDs]):
execution_args.append({
add_data: {'bbox': bbox, 'time_interval': time_interval},
save: {'eopatch_folder': f'eopatch_{idx}'}
})
Execute the workflow
executor = EOExecutor(workflow, execution_args, save_logs=True)
executor.run(workers=5, multiprocess=True)
executor.make_report()
BrokenProcessPool: A process in the process pool was terminated abruptly while the future was running or pending.