(output_file_paths: Iterator[Path], extra: Dict[str, Any])
| 184 | """ |
| 185 | |
| 186 | def closure(output_file_paths: Iterator[Path], extra: Dict[str, Any]) -> Any: |
| 187 | def get_dataframe_and_delete_file(file_path: Path) -> Any: |
| 188 | with file_path.open("rb") as file_descriptor: |
| 189 | data = pickle.load(file_descriptor) |
| 190 | |
| 191 | file_path.unlink() |
| 192 | return data |
| 193 | |
| 194 | dfs = ( |
| 195 | get_dataframe_and_delete_file(output_file_path) |
| 196 | for output_file_path in output_file_paths |
| 197 | ) |
| 198 | |
| 199 | return reduce_function(dfs, extra) |
| 200 | |
| 201 | return closure |
| 202 |
nothing calls this directly
no test coverage detected
searching dependent graphs…