Worker pool instead of pg2

Due to pg2's distributed nature, moved the logic to a non-distributed version.