Figured out what was wrong with parallel async futures setup.  Working great now!  Also disabled forking on the activity worker as it orphans children otherwise.  Now onto error handling in activities.