Parallelizes target route processing operation process_route_edges_and_wait_times via dask distributed which allows for modular parallelization architecture which in the future could leverage external resources (useful for large graphs, tethering together whole regions, etc.).
TODO: Address GIL locking pandas operations triggering:
distributed.core - WARNING - Event loop was unresponsive in Scheduler for 1.18s. This is often caused by long-running GIL-holding functions or moving large chunks of data. This can cause timeouts and instability.
The solution here will be to also distribute sum of the subroutines being performed within each route processor.
Ensure dictionary roll up (array_bag) working as intended. Currently encountering an unintended NameError.
Partially (incrementally) addressing issue https://github.com/kuanb/peartree/issues/12
Parallelizes target route processing operation
process_route_edges_and_wait_times
via dask distributed which allows for modular parallelization architecture which in the future could leverage external resources (useful for large graphs, tethering together whole regions, etc.).TODO: Address GIL locking pandas operations triggering:
The solution here will be to also distribute sum of the subroutines being performed within each route processor.
Ensure dictionary roll up (
array_bag
) working as intended. Currently encountering an unintendedNameError
.