trying to fix broken pipe error

Author: meetchandan

cadence/activity_loop.py

@@ -38,13 +38,13 @@ def activity_task_loop(worker: Worker):
                 return
             except Exception as ex:
                 logger.error("PollForActivityTask error: %s", ex)
-                continue
-            if err:
-                logger.error("PollForActivityTask failed: %s", err)
                 logger.info(f"trying to restart worker and returning from current method")
                 worker.stop()
                 worker.start()
                 return
+            if err:
+                logger.error("PollForActivityTask failed: %s", err)
+                continue
             task_token = task.task_token
             if not task_token:
                 logger.debug("PollForActivityTask has no task_token (expected): %s", task)