added sample showing how to change log levels

Author: GSmithApps

README.md

@@ -41,6 +41,7 @@ Some examples require extra dependencies. See each sample's directory for specif
   * [hello_async_activity_completion](hello/hello_async_activity_completion.py) - Complete an activity outside of the
     function that was called.
   * [hello_cancellation](hello/hello_cancellation.py) - Manually react to cancellation inside workflows and activities.
+  * [hello_change_log_level](hello/hello_change_log_level.py) - Change the level of workflow task failure from WARN to ERROR.
   * [hello_child_workflow](hello/hello_child_workflow.py) - Execute a child workflow from a workflow.
   * [hello_continue_as_new](hello/hello_continue_as_new.py) - Use continue as new to restart a workflow.
   * [hello_cron](hello/hello_cron.py) - Execute a workflow once a minute.

hello/README.md

@@ -28,6 +28,7 @@ Replace `hello_activity.py` in the command with any other example filename to ru
 * [hello_async_activity_completion](hello_async_activity_completion.py) - Complete an activity outside of the function
   that was called.
 * [hello_cancellation](hello_cancellation.py) - Manually react to cancellation inside workflows and activities.
+* [hello_change_log_level](hello_change_log_level.py) - Change the level of workflow task failure from WARN to ERROR.
 * [hello_child_workflow](hello_child_workflow.py) - Execute a child workflow from a workflow.
 * [hello_continue_as_new](hello_continue_as_new.py) - Use continue as new to restart a workflow.
 * [hello_cron](hello_cron.py) - Execute a workflow once a minute.

hello/hello_change_log_level.py

@@ -0,0 +1,58 @@
+"""
+Changes the log level of workflow task failures from WARN to ERROR.
+"""
+
+import asyncio, logging, sys
+from temporalio import workflow
+from temporalio.client import Client
+from temporalio.worker import Worker
+
+# --- Begin logging set‑up ----------------------------------------------------------
+logging.basicConfig(
+    stream=sys.stdout,
+    level=logging.INFO,
+    format="%(asctime)s  %(levelname)-8s  %(name)s  %(message)s",
+)
+
+
+class CustomLogFilter(logging.Filter):
+    def filter(self, record):
+        msg = record.getMessage()
+        if (
+            msg.startswith("Failed activation on workflow")
+            and " with ID " in msg
+            and " and run ID " in msg
+            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())
+# --- End logging set‑up ----------------------------------------------------------
+
+
+@workflow.defn
+class GreetingWorkflow:
+    @workflow.run
+    async def run(self):
+        raise RuntimeError("This is a test error")
+
+
+async def main():
+    client = await Client.connect("localhost:7233")
+    async with Worker(
+        client,
+        task_queue="hello-task-queue",
+        workflows=[GreetingWorkflow],
+    ):
+        await client.execute_workflow(
+            GreetingWorkflow.run,
+            id="hello-workflow-id",
+            task_queue="hello-task-queue",
+        )
+
+
+if __name__ == "__main__":
+    asyncio.run(main())