From ef1e8a0375a74abca187fdb0d3027c552e618668 Mon Sep 17 00:00:00 2001
From: Chandan Bhattad <cbhattad@noon.com>
Date: Thu, 8 Oct 2020 00:38:13 +0400
Subject: [PATCH 1/4] trying to fix broken pipe error

---
 cadence/activity_loop.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/cadence/activity_loop.py b/cadence/activity_loop.py
index b0cdcce..3e3ea42 100644
--- a/cadence/activity_loop.py
+++ b/cadence/activity_loop.py
@@ -41,7 +41,9 @@ def activity_task_loop(worker: Worker):
                 continue
             if err:
                 logger.error("PollForActivityTask failed: %s", err)
-                continue
+                logger.info(f"trying to restart worker and returning from current method")
+                worker.start()
+                return
             task_token = task.task_token
             if not task_token:
                 logger.debug("PollForActivityTask has no task_token (expected): %s", task)

From e3fb4b14c091e5726c3a5a88aa5995be941b422c Mon Sep 17 00:00:00 2001
From: Chandan Bhattad <cbhattad@noon.com>
Date: Thu, 8 Oct 2020 00:39:07 +0400
Subject: [PATCH 2/4] trying to fix broken pipe error

---
 cadence/activity_loop.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/cadence/activity_loop.py b/cadence/activity_loop.py
index 3e3ea42..99a9676 100644
--- a/cadence/activity_loop.py
+++ b/cadence/activity_loop.py
@@ -42,6 +42,7 @@ def activity_task_loop(worker: Worker):
             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
             task_token = task.task_token

From 6687615bccf606d93ea16f8e0567537c93792381 Mon Sep 17 00:00:00 2001
From: Chandan Bhattad <cbhattad@noon.com>
Date: Thu, 8 Oct 2020 00:47:48 +0400
Subject: [PATCH 3/4] trying to fix broken pipe error

---
 cadence/activity_loop.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/cadence/activity_loop.py b/cadence/activity_loop.py
index 99a9676..b8d1739 100644
--- a/cadence/activity_loop.py
+++ b/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)

From a5efc606737bbed16473be39c46ecb128387c7d2 Mon Sep 17 00:00:00 2001
From: Chandan Bhattad <cbhattad@noon.com>
Date: Thu, 8 Oct 2020 00:52:16 +0400
Subject: [PATCH 4/4] trying to fix broken pipe error

---
 cadence/activity_loop.py | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/cadence/activity_loop.py b/cadence/activity_loop.py
index b8d1739..7c6f261 100644
--- a/cadence/activity_loop.py
+++ b/cadence/activity_loop.py
@@ -38,10 +38,7 @@ def activity_task_loop(worker: Worker):
                 return
             except Exception as ex:
                 logger.error("PollForActivityTask error: %s", ex)
-                logger.info(f"trying to restart worker and returning from current method")
-                worker.stop()
-                worker.start()
-                return
+                raise
             if err:
                 logger.error("PollForActivityTask failed: %s", err)
                 continue