responded to PR comments

Author: GSmithApps

hello/hello_change_log_level.py

@@ -11,6 +11,8 @@
 from temporalio.worker import Worker
 
 # --- Begin logging set‑up ----------------------------------------------------------
+_WORKFLOW_TASK_FAILURE_LOG_PREFIX = "Failed activation on workflow"
+
 logging.basicConfig(
     stream=sys.stdout,
     level=logging.INFO,
@@ -21,15 +23,16 @@
 class CustomLogFilter(logging.Filter):
     def filter(self, record: logging.LogRecord) -> bool:
         if (
-            record.msg.startswith("Failed activation on workflow")
+            record.msg.startswith(_WORKFLOW_TASK_FAILURE_LOG_PREFIX)
             and record.levelno < logging.ERROR
         ):
             record.levelno = logging.ERROR
             record.levelname = logging.getLevelName(logging.ERROR)
         return True
 
 
-logging.getLogger("temporalio.worker._workflow_instance").addFilter(CustomLogFilter())
+for h in logging.getLogger().handlers:
+    h.addFilter(CustomLogFilter())
 # --- End logging set‑up ----------------------------------------------------------
 
 

tests/hello/hello_change_log_level_test.py

@@ -33,7 +33,7 @@ async def test_workflow_with_log_capture(client: Client):
         )
         await asyncio.sleep(
             0.2
-        )  # arbitrary wait to ensure the workflow has started and logged
+        )  # small wait to ensure the workflow has started, failed, and logged
         await handle.terminate()
 
     logger.removeHandler(handler)