(tasks, capitals_list, towns_list)
| 47 | return result |
| 48 | |
| 49 | def parallel_worker(tasks, capitals_list, towns_list): |
| 50 | while True: |
| 51 | if not tasks.qsize() % 1000: |
| 52 | print(tasks.qsize()) |
| 53 | task = tasks.get() |
| 54 | ids = get_way_ids(task[0], task[1], sys.argv[2]) |
| 55 | for id in ids: |
| 56 | if task[0][2] and task[1][2]: |
| 57 | capitals_list.add(id) |
| 58 | else: |
| 59 | towns_list.add(id) |
| 60 | tasks.task_done() |
| 61 | |
| 62 | if len(sys.argv) < 3: |
| 63 | print("road_runner.py <intermediate_dir> <osrm_addr>") |
nothing calls this directly
no test coverage detected