Merge pull request #3 from fastfishio/worker-error-fix

Worker broken pipe error fix

Author: meetchandan

cadence/activity_loop.py

@@ -38,7 +38,7 @@ def activity_task_loop(worker: Worker):
                 return
             except Exception as ex:
                 logger.error("PollForActivityTask error: %s", ex)
-                continue
+                raise
             if err:
                 logger.error("PollForActivityTask failed: %s", err)
                 continue