Remove data from temporary storage See Also -------- finish_task
(key, state, delete=True)
| 271 | |
| 272 | |
| 273 | def release_data(key, state, delete=True): |
| 274 | """Remove data from temporary storage |
| 275 | |
| 276 | See Also |
| 277 | -------- |
| 278 | finish_task |
| 279 | """ |
| 280 | if key in state["waiting_data"]: |
| 281 | assert not state["waiting_data"][key] |
| 282 | del state["waiting_data"][key] |
| 283 | |
| 284 | state["released"].add(key) |
| 285 | |
| 286 | if delete: |
| 287 | del state["cache"][key] |
| 288 | |
| 289 | |
| 290 | def finish_task( |